(Runnable task, Duration duration)
| 33 | } |
| 34 | |
| 35 | Cancellable schedule(Runnable task, Duration duration) { |
| 36 | Task t = new Task(task, clock.nanoTime() + duration.toNanos(), counter++); |
| 37 | tasks.add(t); |
| 38 | return t; |
| 39 | } |
| 40 | |
| 41 | List<Runnable> expired() { |
| 42 | long time = clock.nanoTime(); |