| /dports/science/latte/LATTE-1.2.2/MATRIX/Kernels/ |
| H A D | MatrixFastDotProduct.cu | 28 int i=idx, j=idx, active_threads, sum_index, num_elements=M*M, m, n; in MatrixFastTraceX2Kernel() local
37 active_threads=num_threads; in MatrixFastTraceX2Kernel()
42 while(active_threads>2) { in MatrixFastTraceX2Kernel()
43 if (i==0) intermediate_sums[sum_index][active_threads]=0.0; in MatrixFastTraceX2Kernel()
44 if (i==1) intermediate_sums[sum_index][active_threads+1]=0.0; in MatrixFastTraceX2Kernel()
46 active_threads=active_threads/2+1; in MatrixFastTraceX2Kernel()
49 if (j<active_threads) { in MatrixFastTraceX2Kernel()
|
| /dports/devel/racer/racer-2.1.48/cargo-crates/rustc-rayon-core-0.3.1/src/sleep/ |
| H A D | mod.rs | 18 active_threads: usize, field
29 if self.active_threads == 0 && self.blocked_threads > 0 { in deadlock_check()
53 active_threads: worker_count, in new()
65 debug_assert!(data.active_threads > 0); in mark_blocked()
67 debug_assert!(data.active_threads > 0); in mark_blocked()
68 data.active_threads -= 1; in mark_blocked()
78 debug_assert!(data.active_threads < data.worker_count); in mark_unblocked()
80 data.active_threads += 1; in mark_unblocked()
186 data.active_threads = data.worker_count - data.blocked_threads; in tickle_cold()
330 data.active_threads -= 1; in sleep()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/rustc-rayon-core/src/sleep/ |
| H A D | mod.rs | 18 active_threads: usize, field
29 if self.active_threads == 0 && self.blocked_threads > 0 { in deadlock_check()
53 active_threads: worker_count, in new()
65 debug_assert!(data.active_threads > 0); in mark_blocked()
67 debug_assert!(data.active_threads > 0); in mark_blocked()
68 data.active_threads -= 1; in mark_blocked()
78 debug_assert!(data.active_threads < data.worker_count); in mark_unblocked()
80 data.active_threads += 1; in mark_unblocked()
186 data.active_threads = data.worker_count - data.blocked_threads; in tickle_cold()
330 data.active_threads -= 1; in sleep()
|
| /dports/devel/pthreadpool/pthreadpool-0.1-126-gb8374f8/src/ |
| H A D | pthreads.c | 82 if (pthreadpool_decrement_fetch_relaxed_size_t(&threadpool->active_threads) == 0) { in checkin_worker_thread()
88 if (pthreadpool_decrement_fetch_release_size_t(&threadpool->active_threads) == 0) { in checkin_worker_thread()
103 size_t active_threads = pthreadpool_load_acquire_size_t(&threadpool->active_threads); in wait_worker_threads()
104 if (active_threads == 0) { in wait_worker_threads()
119 active_threads = pthreadpool_load_acquire_size_t(&threadpool->active_threads); in wait_worker_threads()
120 if (active_threads == 0) { in wait_worker_threads()
133 while (pthreadpool_load_acquire_size_t(&threadpool->active_threads) != 0) { in wait_worker_threads()
281 …pthreadpool_store_relaxed_size_t(&threadpool->active_threads, threads_count - 1 /* caller thread *… in pthreadpool_create()
325 …pthreadpool_store_relaxed_size_t(&threadpool->active_threads, threads_count.value - 1 /* caller th… in pthreadpool_parallelize()
409 …pthreadpool_store_relaxed_size_t(&threadpool->active_threads, threads_count - 1 /* caller thread *… in pthreadpool_destroy()
[all …]
|
| H A D | windows.c | 27 if (pthreadpool_decrement_fetch_release_size_t(&threadpool->active_threads) == 0) { in checkin_worker_thread()
34 size_t active_threads = pthreadpool_load_acquire_size_t(&threadpool->active_threads); in wait_worker_threads() local
35 if (active_threads == 0) { in wait_worker_threads()
43 active_threads = pthreadpool_load_acquire_size_t(&threadpool->active_threads); in wait_worker_threads()
44 if (active_threads == 0) { in wait_worker_threads()
52 assert(pthreadpool_load_relaxed_size_t(&threadpool->active_threads) == 0); in wait_worker_threads()
174 …pthreadpool_store_relaxed_size_t(&threadpool->active_threads, threads_count - 1 /* caller thread *… in pthreadpool_create()
219 …pthreadpool_store_relaxed_size_t(&threadpool->active_threads, threads_count.value - 1 /* caller th… in pthreadpool_parallelize()
319 …pthreadpool_store_relaxed_size_t(&threadpool->active_threads, threads_count - 1 /* caller thread *… in pthreadpool_destroy()
|
| /dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/llvm10/llvm-10.0.1.src/projects/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/llvm-devel/llvm-project-f05c95f10fc1d8171071735af8ad3a9e87633120/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/llvm11/llvm-11.0.1.src/projects/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/wasi-compiler-rt12/llvm-project-12.0.1.src/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/wasi-compiler-rt13/llvm-project-13.0.1.src/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/llvm/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/tinygo/tinygo-0.14.1/llvm-project/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/wasi-libcxx/llvm-project-13.0.1.src/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/llvm12/llvm-project-12.0.1.src/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/llvm90/llvm-9.0.1.src/projects/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/llvm80/llvm-8.0.1.src/projects/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/devel/llvm13/llvm-project-13.0.1.src/openmp/runtime/test/worksharing/for/ |
| H A D | omp_for_schedule_auto.c | 25 int* active_threads = (int*)malloc(sizeof(int)*max_threads); in test_omp_for_auto() local
27 active_threads[j] = 0; in test_omp_for_auto()
35 active_threads[omp_get_thread_num()] = 1; in test_omp_for_auto()
49 if(active_threads[j]) in test_omp_for_auto()
52 free(active_threads); in test_omp_for_auto()
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/hotspot/src/share/vm/gc_implementation/g1/ |
| H A D | g1GCPhaseTimes.cpp | 157 double average(uint active_threads){ in average() argument
158 calculate_totals(active_threads); in average()
162 T sum(uint active_threads) { in sum() argument
163 calculate_totals(active_threads); in sum()
167 T minimum(uint active_threads) { in minimum() argument
168 calculate_totals(active_threads); in minimum()
172 T maximum(uint active_threads) { in maximum() argument
173 calculate_totals(active_threads); in maximum()
186 void calculate_totals(uint active_threads){ in calculate_totals() argument
195 for (uint i = 0; i < active_threads; ++i) { in calculate_totals()
[all …]
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/hotspot/src/share/vm/gc_implementation/g1/ |
| H A D | g1GCPhaseTimes.cpp | 157 double average(uint active_threads){ in average() argument
158 calculate_totals(active_threads); in average()
162 T sum(uint active_threads) { in sum() argument
163 calculate_totals(active_threads); in sum()
167 T minimum(uint active_threads) { in minimum() argument
168 calculate_totals(active_threads); in minimum()
172 T maximum(uint active_threads) { in maximum() argument
173 calculate_totals(active_threads); in maximum()
186 void calculate_totals(uint active_threads){ in calculate_totals() argument
195 for (uint i = 0; i < active_threads; ++i) { in calculate_totals()
[all …]
|
| /dports/www/elinks/elinks-0.11.7/src/osdep/beos/ |
| H A D | beos.c | 64 INIT_LIST_HEAD(active_threads);
108 add_to_list(active_threads, thrd); in start_thr()
121 foreach (thrd, active_threads) kill_thread(thrd->tid); in terminate_osdep()
123 while ((p = active_threads.next) != &active_threads) { in terminate_osdep()
|
| /dports/net/freeradius3/freeradius-server-3.0.25/src/main/ |
| H A D | threads.c | 200 atomic_uint32_t active_threads; member
396 num = load(thread_pool.active_threads); in request_enqueue()
703 CAS_INCR(thread_pool.active_threads); in request_dequeue()
705 thread_pool.active_threads++; in request_dequeue()
830 CAS_DECR(thread_pool.active_threads); in request_handler_thread()
837 thread_pool.active_threads--; in request_handler_thread()
1160 store(thread_pool.active_threads, num); in thread_pool_init()
1302 uint32_t active_threads; in thread_pool_manage() local
1335 active_threads = load(thread_pool.active_threads); in thread_pool_manage()
1337 active_threads = thread_pool.active_threads; in thread_pool_manage()
[all …]
|
| /dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/python/rml/ |
| H A D | ipc_server.cpp | 387 int active_threads = 0; in propagate_chain_reaction() local
389 ++active_threads; in propagate_chain_reaction()
391 ++active_threads; in propagate_chain_reaction()
393 wake_some( 0, active_threads ); in propagate_chain_reaction()
956 --active_threads; in wake_some()
972 while( active_threads ) { in wake_some()
974 --active_threads; in wake_some()
1044 int active_threads = 0; in adjust_job_count_estimate() local
1046 ++active_threads; in adjust_job_count_estimate()
1048 ++active_threads; in adjust_job_count_estimate()
[all …]
|
| /dports/devel/tbb/oneTBB-2020.3/python/rml/ |
| H A D | ipc_server.cpp | 387 int active_threads = 0; in propagate_chain_reaction() local
389 ++active_threads; in propagate_chain_reaction()
391 ++active_threads; in propagate_chain_reaction()
393 wake_some( 0, active_threads ); in propagate_chain_reaction()
956 --active_threads; in wake_some()
972 while( active_threads ) { in wake_some()
974 --active_threads; in wake_some()
1044 int active_threads = 0; in adjust_job_count_estimate() local
1046 ++active_threads; in adjust_job_count_estimate()
1048 ++active_threads; in adjust_job_count_estimate()
[all …]
|
| /dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/python/rml/ |
| H A D | ipc_server.cpp | 387 int active_threads = 0; in propagate_chain_reaction() local
389 ++active_threads; in propagate_chain_reaction()
391 ++active_threads; in propagate_chain_reaction()
393 wake_some( 0, active_threads ); in propagate_chain_reaction()
956 --active_threads; in wake_some()
972 while( active_threads ) { in wake_some()
974 --active_threads; in wake_some()
1044 int active_threads = 0; in adjust_job_count_estimate() local
1046 ++active_threads; in adjust_job_count_estimate()
1048 ++active_threads; in adjust_job_count_estimate()
[all …]
|