}
private boolean pumpTask() {
- // First finish existing executions
- if(!processor.freeScheduling.isEmpty()) {
- tasks.add(processor.freeScheduling.removeFirst());
- return true;
- }
- // Check for new tasks
- if(!processor.topLevelTasks.isEmpty()) {
- tasks.add(processor.topLevelTasks.removeFirst());
- return true;
- }
- return false;
+ return processor.scheduling.pumpTask(tasks);
}
ArrayList<SessionTask> newTasks(boolean doWait, ArrayList<SessionTask> tasks) {