| /dports/net-im/libsignal-client/libsignal-client-0.9.6/cargo-crates/loom-0.4.0/src/rt/ |
| H A D | atomic.rs | 377 threads: &mut thread::Set, in load()
384 self.track_load(threads); in load()
398 threads: &mut thread::Set, in store()
428 first_seen.touch(threads); in store()
443 threads: &mut thread::Set, in rmw()
454 self.track_load(threads); in rmw()
518 .thread("load", threads.active_id(), self.loaded_locations[threads]) in track_load()
584 threads.active_id(), in track_store()
657 threads: &thread::Set, in match_load_to_stores()
814 self.0[threads.active_id().as_usize()] = threads.active_atomic_version(); in touch()
[all …]
|
| H A D | execution.rs | 15 pub(crate) threads: thread::Set, field
59 threads, in new()
100 let mut threads = self.threads; in step() localVariable
110 threads.clear(id); in step()
115 threads, in step()
200 self.threads.set_active(next); in schedule()
204 if !self.threads.is_active() { in schedule()
210 self.threads in schedule()
221 let threads = &mut self.threads; in schedule() localVariable
222 let th_id = threads.active_id(); in schedule()
[all …]
|
| /dports/misc/xd-rust/delan-xd-4bdbb191ed6d/cargo-crates/loom-0.3.6/src/rt/ |
| H A D | atomic.rs | 377 threads: &mut thread::Set, in load()
384 self.track_load(threads); in load()
398 threads: &mut thread::Set, in store()
428 first_seen.touch(threads); in store()
443 threads: &mut thread::Set, in rmw()
454 self.track_load(threads); in rmw()
518 .thread("load", threads.active_id(), self.loaded_locations[threads]) in track_load()
584 threads.active_id(), in track_store()
657 threads: &thread::Set, in match_load_to_stores()
814 self.0[threads.active_id().as_usize()] = threads.active_atomic_version(); in touch()
[all …]
|
| H A D | execution.rs | 15 pub(crate) threads: thread::Set, field
59 threads, in new()
100 let mut threads = self.threads; in step() localVariable
110 threads.clear(id); in step()
115 threads, in step()
200 self.threads.set_active(next); in schedule()
204 if !self.threads.is_active() { in schedule()
210 self.threads in schedule()
221 let threads = &mut self.threads; in schedule() localVariable
222 let th_id = threads.active_id(); in schedule()
[all …]
|
| /dports/print/texlive-base/texlive-20150521-source/utils/asymptote/ |
| H A D | fftw++.h | 198 threads(threads), mean(mean), stdev(stdev) {} in threaddata()
335 doubles(doubles), sign(sign), threads(threads), in doubles()
415 threads=1; in time()
477 if(threads > 1) data=lookup(inplace,threads);
478 threads=data.threads > 0 ? data.threads : 1;
634 threads(threads) { in threads() argument
728 nx(nx), threads(threads), inplace(inplace) {} in keytype1()
734 (a.threads < b.threads || (a.threads == b.threads && in operator()
746 nx(nx), ny(ny), threads(threads), inplace(inplace) {} in keytype2()
898 threads=S1.threads;
[all …]
|
| /dports/math/primecount/primecount-7.2/src/ |
| H A D | api.cpp | 56 int64_t pi(int64_t x, int threads) in pi() argument
64 return pi_legendre(x, threads); in pi()
68 return pi_meissel(x, threads); in pi()
71 return pi_gourdon_64(x, threads); in pi()
96 int128_t pi(int128_t x, int threads) in pi() argument
100 return pi((int64_t) x, threads); in pi()
102 return pi_gourdon_128(x, threads); in pi()
115 maxint_t res = pi(n, threads); in pi()
126 return pi_gourdon_64(x, threads); in pi_gourdon()
146 return pi_gourdon_128(x, threads); in pi_gourdon()
[all …]
|
| /dports/net/freerdp/freerdp-2.5.0/winpr/libwinpr/synch/test/ |
| H A D | TestSynchMultipleThreads.c | 27 if (!threads[i]) in start_threads()
43 if (!CloseHandle(threads[i])) in close_threads()
57 HANDLE threads[THREADS]; in TestWaitForAll() local
59 if (start_threads(THREADS, threads)) in TestWaitForAll()
79 if (close_threads(THREADS, threads)) in TestWaitForAll()
94 HANDLE threads[THREADS]; in TestWaitOne() local
96 if (start_threads(THREADS, threads)) in TestWaitOne()
115 if (close_threads(THREADS, threads)) in TestWaitOne()
130 HANDLE threads[THREADS]; in TestWaitOneTimeout() local
167 HANDLE threads[THREADS]; in TestWaitOneTimeoutMultijoin() local
[all …]
|
| /dports/multimedia/gmerlin/gmerlin-1.2.0/lib/ |
| H A D | threadpool.c | 47 thread_t * threads; member
75 ret->threads = calloc(num_threads, sizeof(*ret->threads)); in bg_thread_pool_create()
82 pthread_create(&ret->threads[i].t, in bg_thread_pool_create()
95 p->threads[i].do_stop = 1; in bg_thread_pool_destroy()
98 sem_post(&p->threads[i].run_sem); in bg_thread_pool_destroy()
100 pthread_join(p->threads[i].t, NULL); in bg_thread_pool_destroy()
105 free(p->threads); in bg_thread_pool_destroy()
115 p->threads[thread].func = func; in bg_thread_pool_run()
116 p->threads[thread].data = gavl_data; in bg_thread_pool_run()
117 p->threads[thread].start = start; in bg_thread_pool_run()
[all …]
|
| /dports/devel/hpx/hpx-1.2.1/src/lcos/local/ |
| H A D | mutex.cpp | 26 : owner_id_(threads::invalid_thread_id) in mutex()
39 HPX_ASSERT(threads::get_self_ptr() != nullptr); in lock()
44 threads::thread_id_type self_id = threads::get_self_id(); in lock()
54 while (owner_id_ != threads::invalid_thread_id) in lock()
67 HPX_ASSERT(threads::get_self_ptr() != nullptr); in try_lock()
72 if (owner_id_ != threads::invalid_thread_id) in try_lock()
78 threads::thread_id_type self_id = threads::get_self_id(); in try_lock()
92 threads::thread_id_type self_id = threads::get_self_id(); in unlock()
104 owner_id_ = threads::invalid_thread_id; in unlock()
125 threads::thread_id_type self_id = threads::get_self_id(); in try_lock_until()
[all …]
|
| /dports/devel/hpx/hpx-1.2.1/src/runtime/threads/executors/ |
| H A D | current_executor.cpp | 37 threads::thread_result_type
48 return threads::thread_result_type(threads::terminated, in thread_function_nullary()
49 threads::invalid_thread_id); in thread_function_nullary()
58 threads::thread_stacksize stacksize, in add()
68 threads::thread_id_type id = threads::invalid_thread_id; in add()
88 threads::thread_id_type id = threads::invalid_thread_id; in add_at()
89 threads::detail::create_thread( //-V601 in add_at()
95 threads::detail::set_thread_state_timed( in add_at()
134 case threads::detail::min_concurrency: in get_policy_element()
135 case threads::detail::max_concurrency: in get_policy_element()
[all …]
|
| H A D | this_thread_executors.cpp | 41 void set_self_ptr(threads::thread_self*);
109 threads::thread_result_type
124 return threads::thread_result_type(threads::terminated, in thread_function_nullary()
125 threads::invalid_thread_id); in thread_function_nullary()
135 threads::thread_stacksize stacksize, in add()
155 threads::thread_id_type id = threads::invalid_thread_id; in add()
191 threads::thread_id_type id = threads::invalid_thread_id; in add_at()
192 threads::detail::create_thread( //-V601 in add_at()
298 threads::thread_self* self) in this_thread_on_run_exit()
312 threads::thread_self* self_;
[all …]
|
| /dports/net/mpich/mpich-3.4.3/modules/yaksa/test/iov/ |
| H A D | testlist.threads.gen | 2 …ype int -count 17 -seed 1243 -iters 32768 -segments 1 -ordering normal -overlap none -num-threads 4
3 …ort_int -count 17 -seed 1244 -iters 32768 -segments 1 -ordering normal -overlap none -num-threads 4
4 …ouble:2 -count 17 -seed 1245 -iters 32768 -segments 1 -ordering normal -overlap none -num-threads 4
5 …ype int -count 1075 -seed 1246 -iters 128 -segments 1 -ordering normal -overlap none -num-threads 4
6 …ort_int -count 1075 -seed 1247 -iters 128 -segments 1 -ordering normal -overlap none -num-threads 4
8 …ype int -count 65536 -seed 1249 -iters 32 -segments 1 -ordering normal -overlap none -num-threads 4
9 …ort_int -count 65536 -seed 1250 -iters 32 -segments 1 -ordering normal -overlap none -num-threads 4
13 …pe int -count 17 -seed 1252 -iters 32768 -segments 64 -ordering normal -overlap none -num-threads 4
16 …pe int -count 1075 -seed 1255 -iters 128 -segments 64 -ordering normal -overlap none -num-threads 4
19 …pe int -count 65536 -seed 1258 -iters 32 -segments 64 -ordering normal -overlap none -num-threads 4
[all …]
|
| /dports/math/primecount/primecount-7.2/src/app/ |
| H A D | main.cpp | 39 maxint_t AC(maxint_t x, int threads) in AC() argument
75 return AC(x, y, z, k, threads); in AC()
78 maxint_t B(maxint_t x, int threads) in B() argument
105 return B(x, y, threads); in B()
108 maxint_t D(maxint_t x, int threads) in D() argument
213 return Sigma(x, y, threads); in Sigma()
216 maxint_t P2(maxint_t x, int threads) in P2() argument
235 return P2(x, y, threads); in P2()
238 maxint_t S1(maxint_t x, int threads) in S1() argument
258 return S1(x, y, c, threads); in S1()
[all …]
|
| /dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/github.com/minio/argon2/ |
| H A D | argon2.go | 117 if threads < 1 {
123 memory = memory / (syncPoints * uint32(threads)) * (syncPoints * uint32(threads))
124 if memory < 2*syncPoints*uint32(threads) {
125 memory = 2 * syncPoints * uint32(threads)
153 if threads < 1 {
158 memory = memory / (syncPoints * uint32(threads)) * (syncPoints * uint32(threads))
163 B = initBlocks(&h0, B, uint32(threads))
210 j := lane * (uint32(len(B)) / threads)
229 lanes := memory / threads
291 lanes := memory / threads
[all …]
|
| /dports/science/liggghts/LIGGGHTS-PUBLIC-3.8.0-26-g6e873439/lib/cuda/ |
| H A D | fft3d_cuda.cu | 43 dim3 threads; in initfftdata() local
45 threads.y = 1; in initfftdata()
46 threads.z = 1; in initfftdata()
61 dim3 threads; in permute() local
63 threads.y = 1; in permute()
64 threads.z = 1; in permute()
77 dim3 threads; in permute_scale() local
79 threads.y = 1; in permute_scale()
80 threads.z = 1; in permute_scale()
91 dim3 threads; in permute_part() local
[all …]
|
| /dports/devel/hpx/hpx-1.2.1/tests/performance/local/ |
| H A D | timed_task_spawn.cpp | 48 using hpx::threads::get_thread_count;
201 hpx::threads::thread_state_ex_enum ex = hpx::threads::wait_signaled in invoke_worker_timed_no_suspension()
205 return hpx::threads::thread_result_type(hpx::threads::terminated, in invoke_worker_timed_no_suspension()
210 hpx::threads::thread_state_ex_enum ex = hpx::threads::wait_signaled in invoke_worker_timed_suspension()
218 return hpx::threads::thread_result_type(hpx::threads::terminated, in invoke_worker_timed_suspension()
234 , hpx::threads::pending in stage_worker_static_balanced_stackbased()
243 , hpx::threads::pending in stage_worker_static_balanced_stackbased()
259 , hpx::threads::pending in stage_worker_static_imbalanced()
268 , hpx::threads::pending in stage_worker_static_imbalanced()
284 , hpx::threads::pending in stage_worker_round_robin()
[all …]
|
| /dports/devel/p5-Thread-Suspend/Thread-Suspend-1.23/t/ |
| H A D | 01_self.t | 12 use threads;
13 use threads::shared;
37 my $tid = threads->tid();
38 threads->self()->suspend();
48 my @threads;
49 push(@threads, threads->create('checker2')) for (1..$nthreads);
60 while (my $thr = shift(@threads)) {
63 is(scalar(threads->is_suspended()), scalar(@threads)+1, "Threads suspended");
69 is(scalar(threads->is_suspended()), scalar(@threads)+1, "Threads suspended");
75 is(scalar(threads->is_suspended()), scalar(@threads)+1, "Threads suspended");
[all …]
|
| /dports/devel/hpx/hpx-1.2.1/src/util/ |
| H A D | interval_timer.cpp | 128 threads::set_thread_state(id_, threads::pending, in stop_locked()
129 threads::wait_abort, threads::thread_priority_boost, ec); in stop_locked()
187 return threads::thread_result_type(threads::terminated, in evaluate()
194 return threads::thread_result_type(threads::terminated, in evaluate()
224 return threads::thread_result_type(threads::terminated, in evaluate()
225 threads::invalid_thread_id); in evaluate()
233 using namespace hpx::threads; in schedule_thread()
238 threads::thread_id_type id; in schedule_thread()
261 threads::set_thread_state(id, in schedule_thread()
263 threads::pending, threads::wait_signaled, in schedule_thread()
[all …]
|
| /dports/devel/hpx/hpx-1.2.1/tests/performance/local/htts_v2/ |
| H A D | htts2_hpx.cpp | 64 hpx::threads::thread_state_ex_enum ex = hpx::threads::wait_signaled in payload_thread_function()
69 return hpx::threads::thread_result_type(hpx::threads::terminated, in payload_thread_function()
70 hpx::threads::invalid_thread_id); in payload_thread_function()
82 hpx::threads::register_work( in stage_tasks()
86 , hpx::threads::pending in stage_tasks()
96 hpx::threads::register_thread_plain( in stage_tasks()
100 , hpx::threads::pending in stage_tasks()
156 hpx::threads::register_work( in kernel()
159 , hpx::threads::pending in kernel()
189 , nullptr, hpx::threads::pending in kernel()
[all …]
|
| /dports/benchmarks/apib/apib-APIB_1_2_1_RC1/test/ |
| H A D | io_test.cc | 79 RecordStop(threads);
98 RecordStop(threads);
123 RecordStop(threads);
147 RecordStop(threads);
169 RecordStop(threads);
189 RecordStop(threads);
209 RecordStop(threads);
235 RecordStop(threads);
257 RecordStop(threads);
282 RecordStop(threads);
[all …]
|
| /dports/x11-drivers/xf86-video-intel/xf86-video-intel-31486f40f8e8f8923ca0799aea84b58799754564/src/sna/ |
| H A D | sna_threads.c | 54 } *threads; variable
153 threads = malloc (sizeof(threads[0])*max_threads); in sna_threads_init()
154 if (threads == NULL) in sna_threads_init()
161 threads[n].func = NULL; in sna_threads_init()
162 threads[n].arg = NULL; in sna_threads_init()
184 threads[id].func = func; in sna_threads_run()
185 threads[id].arg = arg; in sna_threads_run()
198 if (t == threads[0].thread) in sna_threads_trap()
208 threads[n].func = NULL; in sna_threads_trap()
225 while (threads[n].func) in sna_threads_wait()
[all …]
|
| /dports/math/py-pyFFTW/pyFFTW-0.13.0/pyfftw/interfaces/ |
| H A D | scipy_fft.py | 128 threads = _workers_to_threads(workers)
142 threads = _workers_to_threads(workers)
157 threads = _workers_to_threads(workers)
345 planner_effort=planner_effort, threads=threads,
365 planner_effort=planner_effort, threads=threads,
385 planner_effort=planner_effort, threads=threads,
405 planner_effort=planner_effort, threads=threads,
424 planner_effort=planner_effort, threads=threads,
444 planner_effort=planner_effort, threads=threads,
464 planner_effort=planner_effort, threads=threads,
[all …]
|
| H A D | scipy_fftpack.py | 181 threads = _default_threads(threads)
200 threads = _default_threads(threads)
221 threads = _default_threads(threads)
243 threads = _default_threads(threads)
266 threads = _default_threads(threads)
287 threads = _default_threads(threads)
383 threads = _default_threads(threads)
414 threads = _default_threads(threads)
503 threads = _default_threads(threads)
551 threads = _default_threads(threads)
[all …]
|
| /dports/science/dakota/dakota-6.13.0-release-public.src-UI/packages/external/trilinos/packages/teuchos/core/test/MemoryManagement/ |
| H A D | RCP_MT_UnitTests_Decl.hpp | 102 std::vector<std::thread> threads; in TEUCHOS_UNIT_TEST() local
107 threads[i].join(); in TEUCHOS_UNIT_TEST()
161 threads[i].join(); in TEUCHOS_UNIT_TEST()
207 threads[i].join(); in TEUCHOS_UNIT_TEST()
270 threads[i].join(); in TEUCHOS_UNIT_TEST()
334 threads[i].join(); in TEUCHOS_UNIT_TEST()
398 threads[i].join(); in TEUCHOS_UNIT_TEST()
458 threads[i].join(); in TEUCHOS_UNIT_TEST()
536 threads[i].join(); in TEUCHOS_UNIT_TEST()
609 threads[i].join(); in TEUCHOS_UNIT_TEST()
[all …]
|
| /dports/devel/hpx/hpx-1.2.1/tests/unit/threads/ |
| H A D | thread_suspension_executor.cpp | 22 namespace hpx { namespace threads namespace
34 hpx::threads::thread_id_type id = hpx::threads::get_self_id(); in test_executor_association_yield()
35 hpx::threads::executors::current_executor exec_before in test_executor_association_yield()
36 = hpx::threads::get_executor(id); in test_executor_association_yield()
43 = hpx::threads::get_executor(id); in test_executor_association_yield()
49 void wakeup_thread(hpx::threads::thread_id_type id) in wakeup_thread()
51 hpx::threads::set_thread_state(id, hpx::threads::pending); in wakeup_thread()
56 hpx::threads::thread_id_type id = hpx::threads::get_self_id(); in test_executor_association_suspend()
57 hpx::threads::executors::current_executor exec_before in test_executor_association_suspend()
58 = hpx::threads::get_executor(id); in test_executor_association_suspend()
[all …]
|