[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.89, Sun May 14 04:02:06 2017 UTC revision 1.90, Sun May 14 04:14:09 2017 UTC
# Line 391  Line 391 
391      /**      /**
392       * timed offer times out if full and elements not taken       * timed offer times out if full and elements not taken
393       */       */
394      public void testTimedOffer() throws InterruptedException {      public void testTimedOffer() {
395          final ArrayBlockingQueue q = new ArrayBlockingQueue(2);          final ArrayBlockingQueue q = new ArrayBlockingQueue(2);
396          final CountDownLatch pleaseInterrupt = new CountDownLatch(1);          final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
397          Thread t = newStartedThread(new CheckedRunnable() {          Thread t = newStartedThread(new CheckedRunnable() {
# Line 401  Line 401 
401                  long startTime = System.nanoTime();                  long startTime = System.nanoTime();
402                  assertFalse(q.offer(new Object(), timeoutMillis(), MILLISECONDS));                  assertFalse(q.offer(new Object(), timeoutMillis(), MILLISECONDS));
403                  assertTrue(millisElapsedSince(startTime) >= timeoutMillis());                  assertTrue(millisElapsedSince(startTime) >= timeoutMillis());
404    
405                    Thread.currentThread().interrupt();
406                    try {
407                        q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
408                        shouldThrow();
409                    } catch (InterruptedException success) {}
410                    assertFalse(Thread.interrupted());
411    
412                  pleaseInterrupt.countDown();                  pleaseInterrupt.countDown();
413                  try {                  try {
414                      q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);                      q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);

Legend:
Removed from v.1.89  
changed lines
  Added in v.1.90

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8