Merge pull request #5327 from nubunto/fix/pool-join-hangs

fix: pool_join hangs if no threads are started

1 files changed, 14 insertions, 0 deletions

diff --git a/core/thread/thread_pool.odin b/core/thread/thread_pool.odin
index 59bf90620..15b3a28d2 100644
--- a/core/thread/thread_pool.odin
+++ b/core/thread/thread_pool.odin
@@ -120,6 +120,20 @@ pool_join :: proc(pool: ^Pool) {
 
 	yield()
 
+	unstarted_count: int
+	for t in pool.threads {
+		flags := intrinsics.atomic_load(&t.flags)
+		if .Started not_in flags {
+			unstarted_count += 1
+		}
+	}
+
+	// most likely the user forgot to call `pool_start`
+	// exit here, so we don't hang forever
+	if len(pool.threads) == unstarted_count {
+		return
+	}
+
 	started_count: int
 	for started_count < len(pool.threads) {
 		started_count = 0