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.92 by jsr166, Fri Aug 4 03:30:21 2017 UTC vs.
Revision 1.93 by jsr166, Sun Aug 11 22:29:26 2019 UTC

# Line 340 | Line 340 | public class ArrayBlockingQueueTest exte
340              }});
341  
342          await(pleaseInterrupt);
343 <        assertThreadBlocks(t, Thread.State.WAITING);
343 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
344          t.interrupt();
345          awaitTermination(t);
346          assertEquals(SIZE, q.size());
# Line 382 | Line 382 | public class ArrayBlockingQueueTest exte
382          assertEquals(0, q.take());
383  
384          await(pleaseInterrupt);
385 <        assertThreadBlocks(t, Thread.State.WAITING);
385 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
386          t.interrupt();
387          awaitTermination(t);
388          assertEquals(0, q.remainingCapacity());
# Line 404 | Line 404 | public class ArrayBlockingQueueTest exte
404  
405                  Thread.currentThread().interrupt();
406                  try {
407 <                    q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
407 >                    q.offer(new Object(), randomTimeout(), randomTimeUnit());
408                      shouldThrow();
409                  } catch (InterruptedException success) {}
410                  assertFalse(Thread.interrupted());
411  
412                  pleaseInterrupt.countDown();
413                  try {
414 <                    q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
414 >                    q.offer(new Object(), LONG_DELAY_MS, MILLISECONDS);
415                      shouldThrow();
416                  } catch (InterruptedException success) {}
417                  assertFalse(Thread.interrupted());
418 +
419 +                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
420              }});
421  
422          await(pleaseInterrupt);
423 <        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
423 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.TIMED_WAITING);
424          t.interrupt();
425          awaitTermination(t);
426      }
# Line 459 | Line 461 | public class ArrayBlockingQueueTest exte
461              }});
462  
463          await(pleaseInterrupt);
464 <        assertThreadBlocks(t, Thread.State.WAITING);
464 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
465          t.interrupt();
466          awaitTermination(t);
467      }
# Line 518 | Line 520 | public class ArrayBlockingQueueTest exte
520  
521                  Thread.currentThread().interrupt();
522                  try {
523 <                    q.poll(LONG_DELAY_MS, MILLISECONDS);
523 >                    q.poll(randomTimeout(), randomTimeUnit());
524                      shouldThrow();
525                  } catch (InterruptedException success) {}
526                  assertFalse(Thread.interrupted());
# Line 534 | Line 536 | public class ArrayBlockingQueueTest exte
536              }});
537  
538          await(pleaseInterrupt);
539 <        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
539 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.TIMED_WAITING);
540          t.interrupt();
541          awaitTermination(t);
542          checkEmpty(q);

Diff Legend

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