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

Comparing jsr166/src/test/tck/PriorityBlockingQueueTest.java (file contents):
Revision 1.81 by jsr166, Mon May 28 21:19:50 2018 UTC vs.
Revision 1.84 by jsr166, Thu Sep 5 21:11:13 2019 UTC

# Line 319 | Line 319 | public class PriorityBlockingQueueTest e
319      }
320  
321      /**
322 <     * timed offer does not time out
322 >     * Queue is unbounded, so timed offer never times out
323       */
324      public void testTimedOffer() {
325          final PriorityBlockingQueue q = new PriorityBlockingQueue(2);
# Line 370 | Line 370 | public class PriorityBlockingQueueTest e
370              }});
371  
372          await(pleaseInterrupt);
373 <        assertThreadBlocks(t, Thread.State.WAITING);
373 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
374          t.interrupt();
375          awaitTermination(t);
376      }
# Line 422 | Line 422 | public class PriorityBlockingQueueTest e
422          final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
423          Thread t = newStartedThread(new CheckedRunnable() {
424              public void realRun() throws InterruptedException {
425 –                long startTime = System.nanoTime();
425                  for (int i = 0; i < SIZE; i++)
426                      assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
427  
428                  Thread.currentThread().interrupt();
429                  try {
430 <                    q.poll(LONG_DELAY_MS, MILLISECONDS);
430 >                    q.poll(randomTimeout(), randomTimeUnit());
431                      shouldThrow();
432                  } catch (InterruptedException success) {}
433                  assertFalse(Thread.interrupted());
434  
435                  pleaseInterrupt.countDown();
436                  try {
437 <                    q.poll(LONG_DELAY_MS, MILLISECONDS);
437 >                    q.poll(LONGER_DELAY_MS, MILLISECONDS);
438                      shouldThrow();
439                  } catch (InterruptedException success) {}
440                  assertFalse(Thread.interrupted());
442 –
443 –                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
441              }});
442  
443          await(pleaseInterrupt);
444 <        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
444 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.TIMED_WAITING);
445          t.interrupt();
446          awaitTermination(t);
447      }

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines