--- jsr166/src/test/tck/ScheduledExecutorTest.java 2017/07/17 22:27:31 1.95 +++ jsr166/src/test/tck/ScheduledExecutorTest.java 2018/11/24 21:41:21 1.97 @@ -607,7 +607,7 @@ public class ScheduledExecutorTest exten final ScheduledThreadPoolExecutor p = new ScheduledThreadPoolExecutor(1); try (PoolCleaner cleaner = cleaner(p, releaser)) { for (int i = 0; i < tasks.length; i++) - tasks[i] = p.schedule(new SmallPossiblyInterruptedRunnable(), + tasks[i] = p.schedule(possiblyInterruptedRunnable(SMALL_DELAY_MS), LONG_DELAY_MS, MILLISECONDS); int max = tasks.length; if (tasks[4].cancel(true)) --max; @@ -804,7 +804,7 @@ public class ScheduledExecutorTest exten immediates.forEach( f -> assertTrue(((ScheduledFuture)f).getDelay(NANOSECONDS) <= 0L)); - Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) + Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) .forEach(f -> assertFalse(f.isDone())); try { p.shutdown(); } catch (SecurityException ok) { return; } @@ -858,7 +858,7 @@ public class ScheduledExecutorTest exten assertTrue(q.isEmpty()); - Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) + Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) .forEach(f -> assertTrue(f.isDone())); for (Future f : immediates) assertNull(f.get());