ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/LinkedBlockingQueueTest.java
(Generate patch)

Comparing jsr166/src/test/tck/LinkedBlockingQueueTest.java (file contents):
Revision 1.80 by jsr166, Thu Sep 5 20:54:24 2019 UTC vs.
Revision 1.81 by jsr166, Thu Sep 5 21:11:13 2019 UTC

# Line 463 | Line 463 | public class LinkedBlockingQueueTest ext
463          final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
464          Thread t = newStartedThread(new CheckedRunnable() {
465              public void realRun() throws InterruptedException {
466                long startTime = System.nanoTime();
466                  for (int i = 0; i < SIZE; i++)
467                      assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
468  
# Line 476 | Line 475 | public class LinkedBlockingQueueTest ext
475  
476                  pleaseInterrupt.countDown();
477                  try {
478 <                    q.poll(LONG_DELAY_MS, MILLISECONDS);
478 >                    q.poll(LONGER_DELAY_MS, MILLISECONDS);
479                      shouldThrow();
480                  } catch (InterruptedException success) {}
481                  assertFalse(Thread.interrupted());
483
484                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
482              }});
483  
484          await(pleaseInterrupt);

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines