| /dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/perf/ |
| H A D | time_lru_cache_throughput.cpp | 75 int threads_number; member
91 ,threads_number(a_threads_number) in parameter_pack()
135 ,m_access_sequence(m_parameter_pack.threads_number * per_thread_sample_size ) in throughput()
169 m_barrier.initialize(m_parameter_pack.threads_number); in operator ()()
171 …NativeParallelFor(m_parameter_pack.threads_number,std::bind1st(std::ptr_fun(&_::retrieve_from_cach… in operator ()()
184 int threads_number =tbb::task_scheduler_init::default_num_threads(); in main() local
189 …ops, cache_lru_history_size,time_of_item_use_usec,cache_miss_percent,threads_number,weight_of_init… in main()
194 .arg(p.threads_number,"n-of-threads","number of threads to run on") in main()
|
| /dports/devel/tbb/oneTBB-2020.3/src/perf/ |
| H A D | time_lru_cache_throughput.cpp | 75 int threads_number; member
91 ,threads_number(a_threads_number) in parameter_pack()
135 ,m_access_sequence(m_parameter_pack.threads_number * per_thread_sample_size ) in throughput()
169 m_barrier.initialize(m_parameter_pack.threads_number); in operator ()()
171 …NativeParallelFor(m_parameter_pack.threads_number,std::bind1st(std::ptr_fun(&_::retrieve_from_cach… in operator ()()
184 int threads_number =tbb::task_scheduler_init::default_num_threads(); in main() local
189 …ops, cache_lru_history_size,time_of_item_use_usec,cache_miss_percent,threads_number,weight_of_init… in main()
194 .arg(p.threads_number,"n-of-threads","number of threads to run on") in main()
|
| /dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/perf/ |
| H A D | time_lru_cache_throughput.cpp | 75 int threads_number; member
91 ,threads_number(a_threads_number) in parameter_pack()
135 ,m_access_sequence(m_parameter_pack.threads_number * per_thread_sample_size ) in throughput()
169 m_barrier.initialize(m_parameter_pack.threads_number); in operator ()()
171 …NativeParallelFor(m_parameter_pack.threads_number,std::bind1st(std::ptr_fun(&_::retrieve_from_cach… in operator ()()
184 int threads_number =tbb::task_scheduler_init::default_num_threads(); in main() local
189 …ops, cache_lru_history_size,time_of_item_use_usec,cache_miss_percent,threads_number,weight_of_init… in main()
194 .arg(p.threads_number,"n-of-threads","number of threads to run on") in main()
|
| /dports/devel/onetbb/oneTBB-2021.4.0/test/tbb/ |
| H A D | test_concurrent_monitor.cpp | 52 std::size_t threads_number = utils::get_platform_max_threads(); variable
57 utils::SpinBarrier barrier(threads_number);
61 tbb::task_arena arena(static_cast<int>(threads_number - 1), 0);
76 for (std::size_t i = 0; i < threads_number - 1; ++i) {
|
| H A D | test_concurrent_vector.cpp | 401 void TestConcurrentOperationsWithUnSafeOperations(std::size_t threads_number) { in TestConcurrentOperationsWithUnSafeOperations() argument
420 std::unique_ptr<std::atomic<int>[]> active_threads{ new std::atomic<int>[threads_number]() }; in TestConcurrentOperationsWithUnSafeOperations()
425 auto all_done = [&active_threads, threads_number] { in TestConcurrentOperationsWithUnSafeOperations()
426 for (std::size_t i = 0; i < threads_number; ++i) { in TestConcurrentOperationsWithUnSafeOperations()
433 std::unique_ptr<std::atomic<int>[]> ready_threads{ new std::atomic<int>[threads_number]() }; in TestConcurrentOperationsWithUnSafeOperations()
434 auto all_ready_leave = [&ready_threads, threads_number] { in TestConcurrentOperationsWithUnSafeOperations()
435 for (std::size_t i = 0; i < threads_number; ++i) { in TestConcurrentOperationsWithUnSafeOperations()
441 utils::SpinBarrier barrier(threads_number); in TestConcurrentOperationsWithUnSafeOperations()
516 utils::NativeParallelFor(threads_number, concurrent_func); in TestConcurrentOperationsWithUnSafeOperations()
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/async-global-executor-2.0.2/src/ |
| H A D | threading.rs | 37 let mut threads_number = GLOBAL_EXECUTOR_THREADS_NUMBER.lock().await; in spawn_more_threads() localVariable
41 let count = count.min(config.max_threads - *threads_number); in spawn_more_threads()
46 *threads_number += 1; in spawn_more_threads()
|
| /dports/textproc/jql/jql-3.0.6/cargo-crates/async-global-executor-2.0.2/src/ |
| H A D | threading.rs | 37 let mut threads_number = GLOBAL_EXECUTOR_THREADS_NUMBER.lock().await; in spawn_more_threads() localVariable
41 let count = count.min(config.max_threads - *threads_number); in spawn_more_threads()
46 *threads_number += 1; in spawn_more_threads()
|
| /dports/devel/onetbb/oneTBB-2021.4.0/doc/main/reference/ |
| H A D | constraints_extensions.rst | 45 constraints& set_max_threads_per_core(int threads_number);
78 .. cpp:function:: constraints& set_max_threads_per_core(int threads_number)
80 Sets the ``max_threads_per_core`` field to the ``threads_number``.
|
| /dports/devel/onetbb/oneTBB-2021.4.0/include/oneapi/tbb/ |
| H A D | info.h | 60 constraints& set_max_threads_per_core(int threads_number) { in set_max_threads_per_core()
61 max_threads_per_core = threads_number; in set_max_threads_per_core()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/plugin/keyring_vault/keyring_vault-test/ |
| H A D | keyring_vault-test.cc | 437 unsigned long long threads_number= in main() local
457 otid.resize(threads_number, current_thread_handle); in main()
458 BOOST_SCOPE_EXIT((&otid)(&threads_number)(&tret)(¤t_thread_handle)) in main()
460 for (std::size_t u= 0; u < threads_number; u++) in main()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/plugin/keyring_vault/keyring_vault-test/ |
| H A D | keyring_vault-test.cc | 437 unsigned long long threads_number= in main() local
457 otid.resize(threads_number, current_thread_handle); in main()
458 BOOST_SCOPE_EXIT((&otid)(&threads_number)(&tret)(¤t_thread_handle)) in main()
460 for (std::size_t u= 0; u < threads_number; u++) in main()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/plugin/keyring_vault/keyring_vault-test/ |
| H A D | keyring_vault-test.cc | 437 unsigned long long threads_number= in main() local
457 otid.resize(threads_number, current_thread_handle); in main()
458 BOOST_SCOPE_EXIT((&otid)(&threads_number)(&tret)(¤t_thread_handle)) in main()
460 for (std::size_t u= 0; u < threads_number; u++) in main()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/futures-preview-0.3.0-alpha.19/tests/ |
| H A D | shared.rs | 9 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
12 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/futures/tests/ |
| H A D | shared.rs | 9 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
12 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/futures-0.3.4/tests/ |
| H A D | shared.rs | 9 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
12 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/keyring_vault/keyring_vault-test/ |
| H A D | keyring_vault-test.cc | 313 unsigned long long threads_number = in main() local
318 PSI_NOT_INSTRUMENTED, threads_number * sizeof(*otid), MYF(0))))) in main()
352 for (i = 0; i < threads_number; i++) my_thread_join(&otid[i], &tret); in main()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/plugin/keyring_vault/keyring_vault-test/ |
| H A D | keyring_vault-test.cc | 319 unsigned long long threads_number = in main() local
324 PSI_NOT_INSTRUMENTED, threads_number * sizeof(*otid), MYF(0))))) in main()
358 for (i = 0; i < threads_number; i++) in main()
|
| /dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/futures-0.3.16/tests/ |
| H A D | future_shared.rs | 19 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
22 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/futures-0.3.18/tests/ |
| H A D | future_shared.rs | 19 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
22 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/lang/gleam/gleam-0.18.2/cargo-crates/futures-0.3.18/tests/ |
| H A D | future_shared.rs | 19 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
22 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/futures-0.3.21/tests/ |
| H A D | future_shared.rs | 19 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
22 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/x11-wm/leftwm/leftwm-0.2.11/cargo-crates/futures-0.3.18/tests/ |
| H A D | future_shared.rs | 19 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
22 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/dns/encrypted-dns-server/encrypted-dns-server-0.9.1/cargo-crates/futures-0.3.17/tests/ |
| H A D | future_shared.rs | 19 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
22 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/dns/doh-proxy/doh-proxy-0.9.2/cargo-crates/futures-0.3.17/tests/ |
| H A D | future_shared.rs | 19 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
22 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|
| /dports/net/routinator/routinator-0.10.2/cargo-crates/futures-0.3.15/tests/ |
| H A D | future_shared.rs | 19 fn send_shared_oneshot_and_wait_on_multiple_threads(threads_number: u32) { in send_shared_oneshot_and_wait_on_multiple_threads()
22 let join_handles = (0..threads_number) in send_shared_oneshot_and_wait_on_multiple_threads()
|