| /external/rust/crates/rayon-core/src/ |
| D | test.rs | 20 let n_threads = 16; in start_callback_called() localVariable
23 let barrier = Arc::new(Barrier::new(n_threads + 1)); in start_callback_called()
33 .num_threads(n_threads) in start_callback_called()
41 assert_eq!(n_called.load(Ordering::SeqCst), n_threads); in start_callback_called()
46 let n_threads = 16; in exit_callback_called() localVariable
49 let barrier = Arc::new(Barrier::new(n_threads + 1)); in exit_callback_called()
59 .num_threads(n_threads) in exit_callback_called()
70 assert_eq!(n_called.load(Ordering::SeqCst), n_threads); in exit_callback_called()
75 let n_threads = 16; in handler_panics_handled_correctly() localVariable
78 let start_barrier = Arc::new(Barrier::new(n_threads + 1)); in handler_panics_handled_correctly()
[all …]
|
| D | registry.rs | 221 let n_threads = builder.get_num_threads(); in new() localVariable
224 let (workers, stealers): (Vec<_>, Vec<_>) = (0..n_threads) in new()
237 let logger = Logger::new(n_threads); in new()
241 sleep: Sleep::new(logger, n_threads), in new()
|
| /external/compiler-rt/lib/tsan/benchmarks/ |
| D | mini_bench_local.cc | 27 int n_threads = 0; in main() local
29 n_threads = 4; in main()
32 n_threads = atoi(argv[1]); in main()
33 assert(n_threads > 0 && n_threads <= 32); in main()
37 __FILE__, n_threads, len, kNumIter); in main()
38 a = new int[n_threads * len]; in main()
39 pthread_t *t = new pthread_t[n_threads]; in main()
40 for (int i = 0; i < n_threads; i++) { in main()
43 for (int i = 0; i < n_threads; i++) { in main()
|
| D | vts_many_threads_bench.cc | 45 int n_threads, n_iterations; variable
62 int offset = idx * kNumMutexes / n_threads; in Thread()
74 n_threads = 2; in main()
78 n_threads = atoi(argv[1]); in main()
79 assert(n_threads > 0 && n_threads <= 32); in main()
88 __FILE__, n_threads, n_garbage_threads, n_iterations); in main()
90 pthread_barrier_init(&all_threads_ready, NULL, n_garbage_threads + n_threads + 1); in main()
91 pthread_barrier_init(&main_threads_ready, NULL, n_threads + 1); in main()
93 pthread_t *t = new pthread_t[n_threads]; in main()
100 for (int i = 0; i < n_threads; i++) { in main()
[all …]
|
| D | mini_bench_shared.cc | 27 int n_threads = 0; in main() local
29 n_threads = 4; in main()
32 n_threads = atoi(argv[1]); in main()
33 assert(n_threads > 0 && n_threads <= 32); in main()
37 __FILE__, n_threads, len, kNumIter); in main()
41 pthread_t *t = new pthread_t[n_threads]; in main()
42 for (int i = 0; i < n_threads; i++) { in main()
45 for (int i = 0; i < n_threads; i++) { in main()
|
| D | start_many_threads.cc | 25 int n_threads; in main() local
27 n_threads = 100; in main()
29 n_threads = atoi(argv[1]); in main()
34 printf("%s: n_threads=%d\n", __FILE__, n_threads); in main()
36 pthread_barrier_init(&all_threads_ready, NULL, n_threads + 1); in main()
38 pthread_t *t = new pthread_t[n_threads]; in main()
39 for (int i = 0; i < n_threads; i++) { in main()
45 for (int i = 0; i < n_threads; i++) { in main()
|
| /external/llvm-project/compiler-rt/lib/tsan/benchmarks/ |
| D | mini_bench_local.cpp | 27 int n_threads = 0; in main() local
29 n_threads = 4; in main()
32 n_threads = atoi(argv[1]); in main()
33 assert(n_threads > 0 && n_threads <= 32); in main()
37 __FILE__, n_threads, len, kNumIter); in main()
38 a = new int[n_threads * len]; in main()
39 pthread_t *t = new pthread_t[n_threads]; in main()
40 for (int i = 0; i < n_threads; i++) { in main()
43 for (int i = 0; i < n_threads; i++) { in main()
|
| D | vts_many_threads_bench.cpp | 45 int n_threads, n_iterations; variable
62 int offset = idx * kNumMutexes / n_threads; in Thread()
74 n_threads = 2; in main()
78 n_threads = atoi(argv[1]); in main()
79 assert(n_threads > 0 && n_threads <= 32); in main()
88 __FILE__, n_threads, n_garbage_threads, n_iterations); in main()
90 pthread_barrier_init(&all_threads_ready, NULL, n_garbage_threads + n_threads + 1); in main()
91 pthread_barrier_init(&main_threads_ready, NULL, n_threads + 1); in main()
93 pthread_t *t = new pthread_t[n_threads]; in main()
100 for (int i = 0; i < n_threads; i++) { in main()
[all …]
|
| D | mini_bench_shared.cpp | 27 int n_threads = 0; in main() local
29 n_threads = 4; in main()
32 n_threads = atoi(argv[1]); in main()
33 assert(n_threads > 0 && n_threads <= 32); in main()
37 __FILE__, n_threads, len, kNumIter); in main()
41 pthread_t *t = new pthread_t[n_threads]; in main()
42 for (int i = 0; i < n_threads; i++) { in main()
45 for (int i = 0; i < n_threads; i++) { in main()
|
| D | start_many_threads.cpp | 25 int n_threads; in main() local
27 n_threads = 100; in main()
29 n_threads = atoi(argv[1]); in main()
34 printf("%s: n_threads=%d\n", __FILE__, n_threads); in main()
36 pthread_barrier_init(&all_threads_ready, NULL, n_threads + 1); in main()
38 pthread_t *t = new pthread_t[n_threads]; in main()
39 for (int i = 0; i < n_threads; i++) { in main()
45 for (int i = 0; i < n_threads; i++) { in main()
|
| /external/ltp/testcases/kernel/syscalls/tgkill/ |
| D | tgkill01.c | 24 static int n_threads = 10; variable
63 TST_CHECKPOINT_WAKE2(1, n_threads); in stop_threads()
65 for (i = 0; i < n_threads; i++) { in stop_threads()
81 for (i = 0; i < n_threads; i++) { in run()
106 if (tst_parse_int(str_threads, &n_threads, 1, INT_MAX)) in setup()
109 threads = SAFE_MALLOC(sizeof(*threads) * n_threads); in setup()
116 for (i = 0; i < n_threads; i++) in setup()
119 for (i = 0; i < n_threads; i++) in setup()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_create/ |
| D | 1-6.c | 50 static int n_threads; variable
100 pthread_t threads[n_threads]; in run_hp_threads()
108 it.it_value.tv_sec = n_threads / 20; in run_hp_threads()
109 it.it_value.tv_usec = (n_threads % 20) * 50000; in run_hp_threads()
123 for (i = 0; i < n_threads; i++) { in run_hp_threads()
139 for (i = 0; i < n_threads; i++) in run_hp_threads()
241 n_threads = get_ncpu(); in main()
242 if (n_threads == -1) { in main()
247 n_threads); in main()
250 n_threads = 1; in main()
|
| /external/llvm-project/compiler-rt/test/asan/TestCases/Posix/ |
| D | concurrent_overflow.cpp | 21 const int n_threads = 8; in main() local
22 int i, counter = n_threads; in main()
23 pthread_t thread[n_threads]; in main()
25 for (i = 0; i < n_threads; ++i) in main()
27 for (i = 0; i < n_threads; ++i) in main()
|
| /external/libevent/ |
| D | event_iocp.c | 106 h = CreateIoCompletionPort((HANDLE)fd, port->port, key, port->n_threads); in event_iocp_port_associate_()
189 port->n_threads = n_cpus * 2; in event_iocp_port_launch_()
190 port->threads = mm_calloc(port->n_threads, sizeof(HANDLE)); in event_iocp_port_launch_()
204 for (i=0; i<port->n_threads; ++i) { in event_iocp_port_launch_()
240 for (i=0; i<port->n_threads; ++i) { in event_iocp_notify_all()
|
| D | iocp-internal.h | 81 short n_threads; member
|
| /external/toolchain-utils/crosperf/ |
| D | schedv2.py | 297 n_threads = max(2, min(20, (n_benchmarkruns + 3) // 4))
300 n_threads, n_benchmarkruns))
301 benchmarkruns_per_thread = (n_benchmarkruns + n_threads - 1) // n_threads
303 for i in range(n_threads - 1):
308 self._experiment.benchmark_runs[(n_threads - 1) *
|
| /external/linux-kselftest/tools/testing/selftests/cgroup/ |
| D | test_core.c | 372 int t, c_threads, n_threads = 13; in test_cgcore_proc_migration() local
374 pthread_t threads[n_threads]; in test_cgcore_proc_migration()
389 for (c_threads = 0; c_threads < n_threads; ++c_threads) { in test_cgcore_proc_migration()
395 if (cg_read_lc(dst, "cgroup.threads") != n_threads + 1) in test_cgcore_proc_migration()
|
| /external/rust/crates/rayon-core/src/sleep/ |
| D | mod.rs | 64 pub(super) fn new(logger: Logger, n_threads: usize) -> Sleep { in new()
67 worker_sleep_states: (0..n_threads).map(|_| Default::default()).collect(), in new()
|
| /external/compiler-rt/lib/asan/tests/ |
| D | asan_noinst_test.cc | 171 const int n_threads = 3000; in TEST() local
173 for (int i = 0; i < n_threads; i++) { in TEST()
|
| /external/llvm-project/compiler-rt/lib/asan/tests/ |
| D | asan_noinst_test.cpp | 179 const int n_threads = 3000; in TEST() local
181 for (int i = 0; i < n_threads; i++) { in TEST()
|
| /external/libcxx/utils/google-benchmark/src/ |
| D | benchmark.cc | 125 int n_threads, internal::ThreadTimer* timer, in State() argument
137 threads(n_threads), in State()
|
| /external/llvm-project/libcxx/utils/google-benchmark/src/ |
| D | benchmark.cc | 125 int n_threads, internal::ThreadTimer* timer, in State() argument
137 threads(n_threads), in State()
|
| /external/google-benchmark/src/ |
| D | benchmark.cc | 119 int thread_i, int n_threads, internal::ThreadTimer* timer, in State() argument
131 threads(n_threads), in State()
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | basic_gpu_test.py | 230 n_threads = 4
233 for _ in xrange(n_threads):
|
| /external/llvm-project/llvm/utils/benchmark/src/ |
| D | benchmark.cc | 294 int n_threads, internal::ThreadTimer* timer, in State() argument
308 threads(n_threads), in State()
|