[cvs] / jsr166 / src / test / tck / ArrayBlockingQueueTest.java Repository:
ViewVC logotype

Diff of /jsr166/src/test/tck/ArrayBlockingQueueTest.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.69, Mon Oct 5 23:06:12 2015 UTC revision 1.70, Tue Oct 6 00:03:55 2015 UTC
# Line 451  Line 451 
451          final CountDownLatch aboutToWait = new CountDownLatch(1);          final CountDownLatch aboutToWait = new CountDownLatch(1);
452          Thread t = newStartedThread(new CheckedRunnable() {          Thread t = newStartedThread(new CheckedRunnable() {
453              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
                 for (int i = 0; i < SIZE; ++i) {  
454                      long startTime = System.nanoTime();                      long startTime = System.nanoTime();
455                      assertEquals(i, (int) q.poll(2*LONG_DELAY_MS, MILLISECONDS));                  for (int i = 0; i < SIZE; ++i) {
456                      assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);                      assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
457                  }                  }
                 long startTime = System.nanoTime();  
458                  aboutToWait.countDown();                  aboutToWait.countDown();
459                  try {                  try {
460                      q.poll(2*LONG_DELAY_MS, MILLISECONDS);                      q.poll(LONG_DELAY_MS, MILLISECONDS);
461                      shouldThrow();                      shouldThrow();
462                  } catch (InterruptedException success) {                  } catch (InterruptedException success) {
463                      assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);                      assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
# Line 469  Line 467 
467          await(aboutToWait);          await(aboutToWait);
468          waitForThreadToEnterWaitState(t, LONG_DELAY_MS);          waitForThreadToEnterWaitState(t, LONG_DELAY_MS);
469          t.interrupt();          t.interrupt();
470          awaitTermination(t, LONG_DELAY_MS);          awaitTermination(t);
471          checkEmpty(q);          checkEmpty(q);
472      }      }
473    

Legend:
Removed from v.1.69  
changed lines
  Added in v.1.70

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8