mirrors/Odin
1
0
Fork 0
mirror of https://github.com/odin-lang/Odin.git synced 2026-08-26 06:51:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

thread_pool: an exiting worker must not leave published

Browse Source
This commit is contained in:
kalsprite
2026-08-19 12:09:20 -07:00
parent b7944229e5
commit 239ced8731
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/thread_pool.cpp
View File

@@ -252,7 +252,14 @@ gb_internal THREAD_PROC(thread_pool_thread_proc) {
// if we've done all our work, and there's nothing to steal, go to sleep
pool->tasks_available.store(Someone_Waiting);
if (!pool->running) { break; }
if (!pool->running) {
// do not leave the word published on the way out: a worker still on its way to
// futex_wait would sleep on it, and the destroyer does not broadcast again once it
// has committed to its first join
pool->tasks_available.store(Nobody_Waiting);
futex_broadcast(&pool->tasks_available);
break;
}
futex_wait(&pool->tasks_available, Someone_Waiting);
main_loop_continue:;