equal
deleted
inserted
replaced
829 assertEquals(poolSize, ran.get()); |
829 assertEquals(poolSize, ran.get()); |
830 |
830 |
831 immediates.forEach( |
831 immediates.forEach( |
832 f -> assertTrue(((ScheduledFuture)f).getDelay(NANOSECONDS) <= 0L)); |
832 f -> assertTrue(((ScheduledFuture)f).getDelay(NANOSECONDS) <= 0L)); |
833 |
833 |
834 Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) |
834 Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) |
835 .forEach(f -> assertFalse(f.isDone())); |
835 .forEach(f -> assertFalse(f.isDone())); |
836 |
836 |
837 try { p.shutdown(); } catch (SecurityException ok) { return; } |
837 try { p.shutdown(); } catch (SecurityException ok) { return; } |
838 assertTrue(p.isShutdown()); |
838 assertTrue(p.isShutdown()); |
839 assertTrue(p.isTerminating()); |
839 assertTrue(p.isTerminating()); |
883 assertFalse(p.isTerminating()); |
883 assertFalse(p.isTerminating()); |
884 assertTrue(p.isTerminated()); |
884 assertTrue(p.isTerminated()); |
885 |
885 |
886 assertTrue(q.isEmpty()); |
886 assertTrue(q.isEmpty()); |
887 |
887 |
888 Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) |
888 Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) |
889 .forEach(f -> assertTrue(f.isDone())); |
889 .forEach(f -> assertTrue(f.isDone())); |
890 |
890 |
891 for (Future<?> f : immediates) assertNull(f.get()); |
891 for (Future<?> f : immediates) assertNull(f.get()); |
892 |
892 |
893 assertNull(delayeds.get(0).get()); |
893 assertNull(delayeds.get(0).get()); |