diff options
Diffstat (limited to 'src/thread_pool.cpp')
| -rw-r--r-- | src/thread_pool.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/thread_pool.cpp b/src/thread_pool.cpp index 768a92645..9ac1af039 100644 --- a/src/thread_pool.cpp +++ b/src/thread_pool.cpp @@ -61,9 +61,7 @@ void thread_pool_queue_push(Thread *thread, WorkerTask task) { u64 tail = ((u32)capture) & mask; u64 new_head = (head + 1) & mask; - if (new_head == tail) { - GB_PANIC("Thread Queue Full!\n"); - } + GB_ASSERT_MSG(new_head != tail, "Thread Queue Full!"); // This *must* be done in here, to avoid a potential race condition where we no longer own the slot by the time we're assigning thread->queue[head] = task; @@ -139,7 +137,7 @@ gb_internal THREAD_PROC(thread_pool_thread_proc) { for (;;) { work_start: - if (!pool->running) { + if (!pool->running.load()) { break; } |