diff options
Diffstat (limited to 'source/blender/blenlib/intern/task.c')
| -rw-r--r-- | source/blender/blenlib/intern/task.c | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/source/blender/blenlib/intern/task.c b/source/blender/blenlib/intern/task.c index f2a14aa9363..ba600be870b 100644 --- a/source/blender/blenlib/intern/task.c +++ b/source/blender/blenlib/intern/task.c @@ -1113,15 +1113,22 @@ void BLI_task_parallel_range(int start, int stop, state.iter = start; switch (settings->scheduling_mode) { case TASK_SCHEDULING_STATIC: - state.chunk_size = max_ii(1, (stop - start) / (num_tasks)); + state.chunk_size = max_ii( + settings->min_iter_per_thread, + (stop - start) / (num_tasks)); break; case TASK_SCHEDULING_DYNAMIC: + /* TODO(sergey): Make it configurable from min_iter_per_thread. */ state.chunk_size = 32; break; } num_tasks = min_ii(num_tasks, (stop - start) / state.chunk_size); + /* TODO(sergey): If number of tasks happened to be 1, use single threaded + * path. + */ + /* NOTE: This way we are adding a memory barrier and ensure all worker * threads can read and modify the value, without any locks. */ atomic_fetch_and_add_int32(&state.iter, 0); |