From 32d6025e2935a360d0b6abcab6efe3d27d08f5ad Mon Sep 17 00:00:00 2001 From: Christoffer Lerno Date: Wed, 31 Dec 2025 00:43:19 +0100 Subject: [PATCH] Add panics just in case. --- lib/std/threads/fixed_pool.c3 | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/std/threads/fixed_pool.c3 b/lib/std/threads/fixed_pool.c3 index 89e95a94d..d349f18cc 100644 --- a/lib/std/threads/fixed_pool.c3 +++ b/lib/std/threads/fixed_pool.c3 @@ -74,8 +74,8 @@ fn void? FixedThreadPool.join(&self) @maydiscard // Remove optional in 0.8.0 self.joining = true; do { - self.notify.broadcast(); - self.collect.wait(&self.mu); + self.notify.broadcast()!!; + self.collect.wait(&self.mu)!!; } while (self.qindex != 0 || self.qworking != 0); self.joining = false; } @@ -171,7 +171,7 @@ fn int process_work(void* self_arg) @private // Wait for work. while (self.qindex == 0) { - if (self.joining && self.qworking == 0) self.collect.signal(); + if (self.joining && self.qworking == 0) self.collect.signal()!!; if (self.stop) { // Shutdown requested. @@ -179,7 +179,7 @@ fn int process_work(void* self_arg) @private self.mu.unlock(); return 0; } - self.notify.wait(&self.mu); + self.notify.wait(&self.mu)!!; if (self.stop_now) { // Shutdown requested.