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.69 by jsr166, Sat Feb 18 01:17:06 2017 UTC vs.
Revision 1.70 by jsr166, Sat Feb 18 16:37:49 2017 UTC

#	Line 15 | Line 15 | import java.util.List;
15		import java.util.NoSuchElementException;
16		import java.util.Queue;
17		import java.util.concurrent.BlockingQueue;
18	+	import java.util.concurrent.Callable;
19		import java.util.concurrent.CountDownLatch;
20		import java.util.concurrent.Executors;
21		import java.util.concurrent.ExecutorService;
#	Line 739 | Line 740 | public class LinkedTransferQueueTest ext
740		}});
741
742		threadStarted.await();
743	<	waitForThreadToEnterWaitState(t);
744	<	assertEquals(1, q.getWaitingConsumerCount());
745	<	assertTrue(q.hasWaitingConsumer());
743	>	Callable<Boolean> oneConsumer
744	>	= new Callable<Boolean>() { public Boolean call() {
745	>	return q.hasWaitingConsumer()
746	>	&& q.getWaitingConsumerCount() == 1; }};
747	>	waitForThreadToEnterWaitState(t, oneConsumer);
748
749		assertTrue(q.offer(one));
750		assertEquals(0, q.getWaitingConsumerCount());
#	Line 777 | Line 780 | public class LinkedTransferQueueTest ext
780		}});
781
782		threadStarted.await();
783	<	waitForThreadToEnterWaitState(t);
784	<	assertEquals(1, q.size());
783	>	Callable<Boolean> oneElement
784	>	= new Callable<Boolean>() { public Boolean call() {
785	>	return !q.isEmpty() && q.size() == 1; }};
786	>	waitForThreadToEnterWaitState(t, oneElement);
787	>
788		assertSame(five, q.poll());
789		checkEmpty(q);
790		awaitTermination(t);

Diff Legend

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