Lines Matching refs:task
113 // The task currently being dispatched to the GangWorkers.
138 void coordinator_execute_on_workers(AbstractGangTask* task, uint num_workers) {
140 _task = task;
157 // Wait for the coordinator to dispatch a task.
169 // Mark that the worker is done with the task.
201 void coordinator_execute_on_workers(AbstractGangTask* task, uint num_workers) {
204 _task = task;
268 void WorkGang::run_task(AbstractGangTask* task) {
269 run_task(task, active_workers());
272 void WorkGang::run_task(AbstractGangTask* task, uint num_workers) {
274 "Trying to execute task %s with %u workers which is more than the amount of total workers %u.",
275 task->name(), num_workers, total_workers());
276 guarantee(num_workers > 0, "Trying to execute task %s with zero workers", task->name());
279 _dispatcher->coordinator_execute_on_workers(task, num_workers);
330 log_develop_trace(gc, workgang)("Running work gang: %s task: %s worker: %u", name(), data._task->name(), data._worker_id);
334 log_develop_trace(gc, workgang)("Finished work gang: %s task: %s worker: %u thread: " PTR_FORMAT,
428 assert(t < _n_tasks, "bad task id.");