753 |
|
p.setContinueExistingPeriodicTasksAfterShutdownPolicy(false); |
754 |
|
assertTrue(p.getExecuteExistingDelayedTasksAfterShutdownPolicy()); |
755 |
|
assertFalse(p.getContinueExistingPeriodicTasksAfterShutdownPolicy()); |
756 |
+ |
long initialDelay = LONG_DELAY_MS; |
757 |
|
ScheduledFuture task = |
758 |
< |
p.scheduleAtFixedRate(new NoOpRunnable(), 5, 5, MILLISECONDS); |
758 |
> |
p.scheduleAtFixedRate(new NoOpRunnable(), initialDelay, |
759 |
> |
5, MILLISECONDS); |
760 |
|
try { p.shutdown(); } catch (SecurityException ok) { return; } |
761 |
|
assertTrue(p.isShutdown()); |
760 |
– |
BlockingQueue q = p.getQueue(); |
762 |
|
assertTrue(p.getQueue().isEmpty()); |
763 |
|
assertTrue(task.isDone()); |
764 |
|
assertTrue(task.isCancelled()); |
765 |
< |
assertTrue(p.awaitTermination(SMALL_DELAY_MS, MILLISECONDS)); |
765 |
< |
assertTrue(p.isTerminated()); |
765 |
> |
joinPool(p); |
766 |
|
} |
767 |
|
|
768 |
|
/** |