ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/LinkedTransferQueueTest.java

Comparing jsr166/src/test/tck/LinkedTransferQueueTest.java (file contents):
Revision 1.38 by jsr166, Thu Nov 4 01:04:54 2010 UTC vs.
Revision 1.40 by jsr166, Thu Nov 18 18:37:55 2010 UTC

#	Line 566 | Line 566 | public class LinkedTransferQueueTest ext
566		public void testToArray2() {
567		LinkedTransferQueue<Integer> q = populatedQueue(SIZE);
568		Integer[] ints = new Integer[SIZE];
569	<	assertSame(ints, q.toArray(ints));
569	>	Integer[] array = q.toArray(ints);
570	>	assertSame(ints, array);
571		for (int i = 0; i < ints.length; i++) {
572		assertSame(ints[i], q.poll());
573		}
#	Line 1071 | Line 1072 | public class LinkedTransferQueueTest ext
1072		}
1073
1074		/**
1075	<	* tryTransfer waits the amount given if interrupted, and
1076	<	* throws interrupted exception
1075	>	* tryTransfer waits the amount given, and throws
1076	>	* InterruptedException when interrupted.
1077		*/
1078		public void testTryTransfer5() throws InterruptedException {
1079		final LinkedTransferQueue q = new LinkedTransferQueue();
1080		final CountDownLatch threadStarted = new CountDownLatch(1);
1081	+	assertTrue(q.isEmpty());
1082
1083		Thread t = newStartedThread(new CheckedRunnable() {
1084		public void realRun() throws InterruptedException {
#	Line 1087 | Line 1089 | public class LinkedTransferQueueTest ext
1089		shouldThrow();
1090		} catch (InterruptedException success) {}
1091		assertTrue(millisElapsedSince(t0) >= SHORT_DELAY_MS);
1092	+	assertTrue(millisElapsedSince(t0) < MEDIUM_DELAY_MS);
1093		}});
1094
1095		threadStarted.await();
1096	+	while (q.isEmpty())
1097	+	Thread.yield();
1098		Thread.sleep(SHORT_DELAY_MS);
1099		t.interrupt();
1100		awaitTermination(t, MEDIUM_DELAY_MS);

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines