()
| 329 | } |
| 330 | |
| 331 | private void shutdown() throws InterruptedException { |
| 332 | for (Fiber f : live) { |
| 333 | f.stopped = true; |
| 334 | f.runner.cancel(true); |
| 335 | serviceAndCull(); |
| 336 | } |
| 337 | |
| 338 | live.clear(); |
| 339 | models.remove(Thread.currentThread()); |
| 340 | } |
| 341 | |
| 342 | public Fiber run(String tag, Callable r, Consumer<Throwable> h) throws InterruptedException { |
| 343 | return run(tag, NULL(), discard(), r, h); |
no test coverage detected