Replace atomic fetch_sub with decrement_fetch primitive

Decrement-fetch is a closer match to the primitive used in implementation

1 files changed, 2 insertions, 2 deletions

diff --git a/src/pthreads.c b/src/pthreads.c
index e70ab18..a7e4619 100644
--- a/src/pthreads.c
+++ b/src/pthreads.c
@@ -79,13 +79,13 @@
 
 static void checkin_worker_thread(struct pthreadpool* threadpool) {
 	#if PTHREADPOOL_USE_FUTEX
-		if (pthreadpool_fetch_sub_relaxed_size_t(&threadpool->active_threads, 1) == 1) {
+		if (pthreadpool_decrement_fetch_relaxed_size_t(&threadpool->active_threads) == 0) {
 			pthreadpool_store_relaxed_uint32_t(&threadpool->has_active_threads, 0);
 			futex_wake_all(&threadpool->has_active_threads);
 		}
 	#else
 		pthread_mutex_lock(&threadpool->completion_mutex);
-		if (pthreadpool_fetch_sub_relaxed_size_t(&threadpool->active_threads, 1) == 1) {
+		if (pthreadpool_decrement_fetch_relaxed_size_t(&threadpool->active_threads) == 0) {
 			pthread_cond_signal(&threadpool->completion_condvar);
 		}
 		pthread_mutex_unlock(&threadpool->completion_mutex);