8485868788899091929394
@After public void waitForAllTasks() throws TimeoutException, InterruptedException { waitFor(new Condition() { @Override public boolean isSatisfied() { return nexusScheduler.getActiveTasks().isEmpty(); }
3435363738394041424344
@After public void waitForThreadPool() throws Exception { waitFor(new Condition() { @Override public boolean isSatisfied() { int running = 0; for (Entry<String, List<ScheduledTask<?>>> entry : nexusScheduler.getActiveTasks().entrySet()) {
101102103104105106107108109110111
} private void waitForAllTasksToBeDone() throws TimeoutException, InterruptedException { waitFor(new Condition() { @Override public boolean isSatisfied() { return nexusScheduler.getActiveTasks().isEmpty(); }