ViewVC Help

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

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

Comparing jsr166/src/test/tck/LinkedBlockingQueueTest.java (file contents):
Revision 1.71 by jsr166, Sun May 14 00:48:20 2017 UTC vs.
Revision 1.74 by jsr166, Sun May 14 04:02:06 2017 UTC

#	Line 314 | Line 314 | public class LinkedBlockingQueueTest ext
314		pleaseTake.countDown();
315		q.put(86);
316
317	+	Thread.currentThread().interrupt();
318	+	try {
319	+	q.put(99);
320	+	shouldThrow();
321	+	} catch (InterruptedException success) {}
322	+	assertFalse(Thread.interrupted());
323	+
324		pleaseInterrupt.countDown();
325		try {
326		q.put(99);
#	Line 351 | Line 358 | public class LinkedBlockingQueueTest ext
358		q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
359		shouldThrow();
360		} catch (InterruptedException success) {}
361	+	assertFalse(Thread.interrupted());
362		}});
363
364		await(pleaseInterrupt);
#	Line 448 | Line 456 | public class LinkedBlockingQueueTest ext
456		Thread t = newStartedThread(new CheckedRunnable() {
457		public void realRun() throws InterruptedException {
458		long startTime = System.nanoTime();
459	<	for (int i = 0; i < SIZE; ++i) {
459	>	for (int i = 0; i < SIZE; i++)
460		assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
461	<	}
461	>
462	>	Thread.currentThread().interrupt();
463	>	try {
464	>	q.poll(LONG_DELAY_MS, MILLISECONDS);
465	>	shouldThrow();
466	>	} catch (InterruptedException success) {}
467	>	assertFalse(Thread.interrupted());
468
469		pleaseInterrupt.countDown();
470		try {

Diff Legend

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