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

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

# Line 512 | Line 512 | public class ArrayBlockingQueueTest exte
512          final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
513          Thread t = newStartedThread(new CheckedRunnable() {
514              public void realRun() throws InterruptedException {
515                long startTime = System.nanoTime();
515                  for (int i = 0; i < SIZE; i++)
516                      assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
517  
# Line 525 | Line 524 | public class ArrayBlockingQueueTest exte
524  
525                  pleaseInterrupt.countDown();
526                  try {
527 <                    q.poll(LONG_DELAY_MS, MILLISECONDS);
527 >                    q.poll(LONGER_DELAY_MS, MILLISECONDS);
528                      shouldThrow();
529                  } catch (InterruptedException success) {}
530                  assertFalse(Thread.interrupted());
532
533                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
531              }});
532  
533          await(pleaseInterrupt);

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines