| 10962 | |
| 10963 | |
| 10964 | void Executor::enqueueTaskGroup(const TaskGroupInfo& taskGroup) |
| 10965 | { |
| 10966 | foreach (const TaskInfo& task, taskGroup.tasks()) { |
| 10967 | queuedTasks[task.task_id()] = task; |
| 10968 | } |
| 10969 | |
| 10970 | queuedTaskGroups.push_back(taskGroup); |
| 10971 | } |
| 10972 | |
| 10973 | |
| 10974 | Option<TaskInfo> Executor::dequeueTask(const TaskID& taskId) |