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.74 by jsr166, Sat May 13 22:49:01 2017 UTC vs.
Revision 1.76 by jsr166, Sun May 14 00:48:20 2017 UTC

#	Line 278 | Line 278 | public class LinkedTransferQueueTest ext
278		*/
279		public void testInterruptedTimedPoll() throws InterruptedException {
280		final BlockingQueue<Integer> q = populatedQueue(SIZE);
281	<	final CountDownLatch aboutToWait = new CountDownLatch(1);
281	>	final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
282		Thread t = newStartedThread(new CheckedRunnable() {
283		public void realRun() throws InterruptedException {
284		long startTime = System.nanoTime();
285		for (int i = 0; i < SIZE; ++i)
286		assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
287	<	aboutToWait.countDown();
287	>
288	>	pleaseInterrupt.countDown();
289		try {
290		q.poll(LONG_DELAY_MS, MILLISECONDS);
291		shouldThrow();
292		} catch (InterruptedException success) {}
293	+	assertFalse(Thread.interrupted());
294	+
295		assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
296		}});
297
298	<	await(aboutToWait);
298	>	await(pleaseInterrupt);
299		assertThreadBlocks(t, Thread.State.TIMED_WAITING);
300		t.interrupt();
301		awaitTermination(t);
#	Line 961 | Line 964 | public class LinkedTransferQueueTest ext
964		}});
965
966		await(pleaseInterrupt);
967	<	assertThreadStaysAlive(t);
967	>	assertThreadBlocks(t, Thread.State.TIMED_WAITING);
968		t.interrupt();
969		awaitTermination(t);
970		checkEmpty(q);

Diff Legend

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