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

Comparing jsr166/src/test/tck/DelayQueueTest.java (file contents):
Revision 1.87 by jsr166, Sun May 14 01:30:34 2017 UTC vs.
Revision 1.91 by jsr166, Sun Aug 11 22:29:26 2019 UTC

# Line 69 | Line 69 | public class DelayQueueTest extends JSR1
69          // suppress [overrides] javac warning
70          public int hashCode() { return pseudodelay; }
71          public long getDelay(TimeUnit ignore) {
72 <            return Integer.MIN_VALUE + pseudodelay;
72 >            return (long) Integer.MIN_VALUE + pseudodelay;
73          }
74          public String toString() {
75              return String.valueOf(pseudodelay);
# Line 234 | Line 234 | public class DelayQueueTest extends JSR1
234      }
235  
236      /**
237 <     * addAll(this) throws IAE
237 >     * addAll(this) throws IllegalArgumentException
238       */
239      public void testAddAllSelf() {
240          DelayQueue q = populatedQueue(SIZE);
# Line 357 | Line 357 | public class DelayQueueTest extends JSR1
357              }});
358  
359          await(pleaseInterrupt);
360 <        assertThreadBlocks(t, Thread.State.WAITING);
360 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.WAITING);
361          t.interrupt();
362          awaitTermination(t);
363      }
# Line 416 | Line 416 | public class DelayQueueTest extends JSR1
416  
417                  Thread.currentThread().interrupt();
418                  try {
419 <                    q.poll(LONG_DELAY_MS, MILLISECONDS);
419 >                    q.poll(randomTimeout(), randomTimeUnit());
420                      shouldThrow();
421                  } catch (InterruptedException success) {}
422                  assertFalse(Thread.interrupted());
# Line 432 | Line 432 | public class DelayQueueTest extends JSR1
432              }});
433  
434          await(pleaseInterrupt);
435 <        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
435 >        if (randomBoolean()) assertThreadBlocks(t, Thread.State.TIMED_WAITING);
436          t.interrupt();
437          awaitTermination(t);
438          checkEmpty(q);
# Line 566 | Line 566 | public class DelayQueueTest extends JSR1
566       */
567      public void testToArray() throws InterruptedException {
568          DelayQueue q = populatedQueue(SIZE);
569 <        Object[] o = q.toArray();
570 <        Arrays.sort(o);
571 <        for (int i = 0; i < o.length; i++)
572 <            assertSame(o[i], q.take());
569 >        Object[] a = q.toArray();
570 >        assertSame(Object[].class, a.getClass());
571 >        Arrays.sort(a);
572 >        for (Object o : a)
573 >            assertSame(o, q.take());
574 >        assertTrue(q.isEmpty());
575      }
576  
577      /**
# Line 581 | Line 583 | public class DelayQueueTest extends JSR1
583          PDelay[] array = q.toArray(ints);
584          assertSame(ints, array);
585          Arrays.sort(ints);
586 <        for (int i = 0; i < ints.length; i++)
587 <            assertSame(ints[i], q.remove());
586 >        for (PDelay o : ints)
587 >            assertSame(o, q.remove());
588 >        assertTrue(q.isEmpty());
589      }
590  
591      /**

Diff Legend

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