[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.68, Sun Oct 4 18:49:02 2015 UTC revision 1.69, Mon Oct 5 23:06:12 2015 UTC
# Line 452  Line 452 
452          Thread t = newStartedThread(new CheckedRunnable() {          Thread t = newStartedThread(new CheckedRunnable() {
453              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
454                  for (int i = 0; i < SIZE; ++i) {                  for (int i = 0; i < SIZE; ++i) {
455                      long t0 = System.nanoTime();                      long startTime = System.nanoTime();
456                      assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));                      assertEquals(i, (int) q.poll(2*LONG_DELAY_MS, MILLISECONDS));
457                      assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS);                      assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
458                  }                  }
459                  long t0 = System.nanoTime();                  long startTime = System.nanoTime();
460                  aboutToWait.countDown();                  aboutToWait.countDown();
461                  try {                  try {
462                      q.poll(MEDIUM_DELAY_MS, MILLISECONDS);                      q.poll(2*LONG_DELAY_MS, MILLISECONDS);
463                      shouldThrow();                      shouldThrow();
464                  } catch (InterruptedException success) {                  } catch (InterruptedException success) {
465                      assertTrue(millisElapsedSince(t0) < MEDIUM_DELAY_MS);                      assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
466                  }                  }
467              }});              }});
468    
469          aboutToWait.await();          await(aboutToWait);
470          waitForThreadToEnterWaitState(t, SMALL_DELAY_MS);          waitForThreadToEnterWaitState(t, LONG_DELAY_MS);
471          t.interrupt();          t.interrupt();
472          awaitTermination(t, MEDIUM_DELAY_MS);          awaitTermination(t, LONG_DELAY_MS);
473          checkEmpty(q);          checkEmpty(q);
474      }      }
475    

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

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8