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

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

# Line 291 | Line 291 | public class LinkedBlockingQueueTest ext
291              }});
292  
293          await(pleaseInterrupt);
294 <        assertThreadBlocks(t, Thread.State.WAITING);
294 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
295          t.interrupt();
296          awaitTermination(t);
297          assertEquals(SIZE, q.size());
# Line 333 | Line 333 | public class LinkedBlockingQueueTest ext
333          assertEquals(0, q.take());
334  
335          await(pleaseInterrupt);
336 <        assertThreadBlocks(t, Thread.State.WAITING);
336 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
337          t.interrupt();
338          awaitTermination(t);
339          assertEquals(0, q.remainingCapacity());
# Line 349 | Line 349 | public class LinkedBlockingQueueTest ext
349              public void realRun() throws InterruptedException {
350                  q.put(new Object());
351                  q.put(new Object());
352 –
352                  long startTime = System.nanoTime();
353 +
354                  assertFalse(q.offer(new Object(), timeoutMillis(), MILLISECONDS));
355                  assertTrue(millisElapsedSince(startTime) >= timeoutMillis());
356  
357                  Thread.currentThread().interrupt();
358                  try {
359 <                    q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
359 >                    q.offer(new Object(), randomTimeout(), randomTimeUnit());
360                      shouldThrow();
361                  } catch (InterruptedException success) {}
362                  assertFalse(Thread.interrupted());
363  
364                  pleaseInterrupt.countDown();
365                  try {
366 <                    q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
366 >                    q.offer(new Object(), LONGER_DELAY_MS, MILLISECONDS);
367                      shouldThrow();
368                  } catch (InterruptedException success) {}
369                  assertFalse(Thread.interrupted());
370              }});
371  
372          await(pleaseInterrupt);
373 <        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
373 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.TIMED_WAITING);
374          t.interrupt();
375          awaitTermination(t);
376      }
# Line 411 | Line 411 | public class LinkedBlockingQueueTest ext
411              }});
412  
413          await(pleaseInterrupt);
414 <        assertThreadBlocks(t, Thread.State.WAITING);
414 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
415          t.interrupt();
416          awaitTermination(t);
417      }
# Line 463 | Line 463 | public class LinkedBlockingQueueTest ext
463          final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
464          Thread t = newStartedThread(new CheckedRunnable() {
465              public void realRun() throws InterruptedException {
466 –                long startTime = System.nanoTime();
466                  for (int i = 0; i < SIZE; i++)
467                      assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
468  
469                  Thread.currentThread().interrupt();
470                  try {
471 <                    q.poll(LONG_DELAY_MS, MILLISECONDS);
471 >                    q.poll(randomTimeout(), randomTimeUnit());
472                      shouldThrow();
473                  } catch (InterruptedException success) {}
474                  assertFalse(Thread.interrupted());
475  
476                  pleaseInterrupt.countDown();
477                  try {
478 <                    q.poll(LONG_DELAY_MS, MILLISECONDS);
478 >                    q.poll(LONGER_DELAY_MS, MILLISECONDS);
479                      shouldThrow();
480                  } catch (InterruptedException success) {}
481                  assertFalse(Thread.interrupted());
483 –
484 –                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
482              }});
483  
484          await(pleaseInterrupt);
485 <        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
485 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.TIMED_WAITING);
486          t.interrupt();
487          awaitTermination(t);
488          checkEmpty(q);

Diff Legend

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