# | Line 750 | Line 750 | public class DelayQueueTest extends JSR1 | |
---|---|---|
750 | ExecutorService executor = Executors.newFixedThreadPool(2); | |
751 | executor.execute(new CheckedRunnable() { | |
752 | public void realRun() throws InterruptedException { | |
753 | < | threadAssertNull(q.poll()); |
754 | < | threadAssertTrue(null != q.poll(MEDIUM_DELAY_MS, MILLISECONDS)); |
755 | < | threadAssertTrue(q.isEmpty()); |
753 | > | assertNull(q.poll()); |
754 | > | assertTrue(null != q.poll(MEDIUM_DELAY_MS, MILLISECONDS)); |
755 | > | assertTrue(q.isEmpty()); |
756 | }}); | |
757 | ||
758 | executor.execute(new CheckedRunnable() { |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |