649 |
|
final CustomExecutor p = new CustomExecutor(1); |
650 |
|
try (PoolCleaner cleaner = cleaner(p, releaser)) { |
651 |
|
for (int i = 0; i < tasks.length; i++) |
652 |
< |
tasks[i] = p.schedule(new SmallPossiblyInterruptedRunnable(), |
652 |
> |
tasks[i] = p.schedule(possiblyInterruptedRunnable(SMALL_DELAY_MS), |
653 |
|
LONG_DELAY_MS, MILLISECONDS); |
654 |
|
int max = tasks.length; |
655 |
|
if (tasks[4].cancel(true)) --max; |
845 |
|
immediates.forEach( |
846 |
|
f -> assertTrue(((ScheduledFuture)f).getDelay(NANOSECONDS) <= 0L)); |
847 |
|
|
848 |
< |
Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) |
848 |
> |
Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) |
849 |
|
.forEach(f -> assertFalse(f.isDone())); |
850 |
|
|
851 |
|
try { p.shutdown(); } catch (SecurityException ok) { return; } |
899 |
|
|
900 |
|
assertTrue(q.isEmpty()); |
901 |
|
|
902 |
< |
Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) |
902 |
> |
Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) |
903 |
|
.forEach(f -> assertTrue(f.isDone())); |
904 |
|
|
905 |
|
for (Future<?> f : immediates) assertNull(f.get()); |