Commit c3a92ba0 by Marcus Winter

mtapi_c: do not notify all worker threads on task start, but just the one the…

mtapi_c: do not notify all worker threads on task start, but just the one the task was initially assigned to
parent e2e64a87
...@@ -586,11 +586,9 @@ mtapi_boolean_t embb_mtapi_scheduler_schedule_task( ...@@ -586,11 +586,9 @@ mtapi_boolean_t embb_mtapi_scheduler_schedule_task(
} }
if (pushed) { if (pushed) {
/* signal all threads */ /* signal the worker thread a task was pushed to */
for (ii = 0; ii < scheduler->worker_count; ii++) { embb_condition_notify_one(
embb_condition_notify_one( &scheduler->worker_contexts[ii].work_available);
&scheduler->worker_contexts[ii].work_available);
}
} else { } else {
/* task could not be launched */ /* task could not be launched */
embb_atomic_fetch_and_add_int(&local_action->num_tasks, -1); embb_atomic_fetch_and_add_int(&local_action->num_tasks, -1);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment