Lines Matching refs:memory_order_relaxed
222 if (atomic_fetch_sub_explicit(&threadpool->active_threads, 1, memory_order_relaxed) == 1) { in checkin_worker_thread()
228 if (atomic_fetch_sub_explicit(&threadpool->active_threads, 1, memory_order_relaxed) == 1) { in checkin_worker_thread()
238 …t has_active_threads = atomic_load_explicit(&threadpool->has_active_threads, memory_order_relaxed); in wait_worker_threads()
243 size_t active_threads = atomic_load_explicit(&threadpool->active_threads, memory_order_relaxed); in wait_worker_threads()
255 has_active_threads = atomic_load_explicit(&threadpool->has_active_threads, memory_order_relaxed); in wait_worker_threads()
260 active_threads = atomic_load_explicit(&threadpool->active_threads, memory_order_relaxed); in wait_worker_threads()
274 while (atomic_load_explicit(&threadpool->active_threads, memory_order_relaxed) != 0) { in wait_worker_threads()
282 size_t actual_value = atomic_load_explicit(value, memory_order_relaxed); in atomic_decrement()
287 value, &actual_value, actual_value - 1, memory_order_relaxed, memory_order_relaxed)) in atomic_decrement()
306 …_1d_t task = (pthreadpool_task_1d_t) atomic_load_explicit(&threadpool->task, memory_order_relaxed); in thread_parallelize_1d()
307 void *const argument = atomic_load_explicit(&threadpool->argument, memory_order_relaxed); in thread_parallelize_1d()
309 size_t range_start = atomic_load_explicit(&thread->range_start, memory_order_relaxed); in thread_parallelize_1d()
323 … size_t item_id = atomic_fetch_sub_explicit(&other_thread->range_end, 1, memory_order_relaxed) - 1; in thread_parallelize_1d()
334 uint32_t command = atomic_load_explicit(&threadpool->command, memory_order_relaxed); in wait_for_new_command()
345 command = atomic_load_explicit(&threadpool->command, memory_order_relaxed); in wait_for_new_command()
356 command = atomic_load_explicit(&threadpool->command, memory_order_relaxed); in wait_for_new_command()
362 …while ((command = atomic_load_explicit(&threadpool->command, memory_order_relaxed)) == last_comman… in wait_for_new_command()
385 const uint32_t flags = atomic_load_explicit(&threadpool->flags, memory_order_relaxed); in thread_main()
464 atomic_store_explicit(&threadpool->has_active_threads, 1, memory_order_relaxed); in pthreadpool_create()
518 atomic_store_explicit(&threadpool->task, task, memory_order_relaxed); in pthreadpool_parallelize_1d()
519 atomic_store_explicit(&threadpool->argument, argument, memory_order_relaxed); in pthreadpool_parallelize_1d()
520 atomic_store_explicit(&threadpool->flags, flags, memory_order_relaxed); in pthreadpool_parallelize_1d()
524 …readpool->active_threads, threadpool->threads_count - 1 /* caller thread */, memory_order_relaxed); in pthreadpool_parallelize_1d()
526 atomic_store_explicit(&threadpool->has_active_threads, 1, memory_order_relaxed); in pthreadpool_parallelize_1d()
534 atomic_store_explicit(&thread->range_start, range_start, memory_order_relaxed); in pthreadpool_parallelize_1d()
535 atomic_store_explicit(&thread->range_end, range_end, memory_order_relaxed); in pthreadpool_parallelize_1d()
536 atomic_store_explicit(&thread->range_length, range_end - range_start, memory_order_relaxed); in pthreadpool_parallelize_1d()
554 const uint32_t old_command = atomic_load_explicit(&threadpool->command, memory_order_relaxed); in pthreadpool_parallelize_1d()
563 atomic_store_explicit(&threadpool->command, new_command, memory_order_relaxed); in pthreadpool_parallelize_1d()
1168 …readpool->active_threads, threadpool->threads_count - 1 /* caller thread */, memory_order_relaxed); in pthreadpool_destroy()