| /external/clang/test/OpenMP/ |
| D | parallel_num_threads_messages.cpp | 12 #define redef_num_threads(a, b) num_threads(a)
16 #pragma omp parallel num_threads // expected-error {{expected '(' after 'num_threads'}} in tmain()
17 …#pragma omp parallel num_threads ( // expected-error {{expected expression}} expected-error {{expe… in tmain()
18 #pragma omp parallel num_threads () // expected-error {{expected expression}} in tmain()
19 …#pragma omp parallel num_threads (argc // expected-error {{expected ')'}} expected-note {{to match… in tmain()
20 …#pragma omp parallel num_threads (argc)) // expected-warning {{extra tokens at the end of '#pragma… in tmain()
21 …#pragma omp parallel num_threads ((argc > 0) ? argv[1] : argv[2]) // expected-error 2 {{expression… in tmain()
22 …#pragma omp parallel num_threads (foobool(argc)), num_threads (true), num_threads (-5) // expected… in tmain()
23 #pragma omp parallel num_threads (S) // expected-error {{'S' does not refer to a value}} in tmain()
24 …#pragma omp parallel num_threads (argv[1]=2) // expected-error {{expected ')'}} expected-note {{to… in tmain()
[all …]
|
| D | parallel_sections_num_threads_messages.cpp | 14 #pragma omp parallel sections num_threads // expected-error {{expected '(' after 'num_threads'}} in tmain()
16 …#pragma omp parallel sections num_threads ( // expected-error {{expected expression}} expected-err… in tmain()
18 #pragma omp parallel sections num_threads () // expected-error {{expected expression}} in tmain()
20 …#pragma omp parallel sections num_threads (argc // expected-error {{expected ')'}} expected-note {… in tmain()
22 …#pragma omp parallel sections num_threads (argc)) // expected-warning {{extra tokens at the end of… in tmain()
24 …#pragma omp parallel sections num_threads ((argc > 0) ? argv[1] : argv[2]) // expected-error 2 {{e… in tmain()
26 …#pragma omp parallel sections num_threads (foobool(argc)), num_threads (true), num_threads (-5) //… in tmain()
28 #pragma omp parallel sections num_threads (S) // expected-error {{'S' does not refer to a value}} in tmain()
30 …#pragma omp parallel sections num_threads (argv[1]=2) // expected-error {{expected ')'}} expected-… in tmain()
32 #pragma omp parallel sections num_threads (argc) in tmain()
[all …]
|
| D | target_parallel_num_threads_messages.cpp | 12 #define redef_num_threads(a, b) num_threads(a)
16 #pragma omp target parallel num_threads // expected-error {{expected '(' after 'num_threads'}} in tmain()
18 …#pragma omp target parallel num_threads ( // expected-error {{expected expression}} expected-error… in tmain()
20 #pragma omp target parallel num_threads () // expected-error {{expected expression}} in tmain()
22 …#pragma omp target parallel num_threads (argc // expected-error {{expected ')'}} expected-note {{t… in tmain()
24 …#pragma omp target parallel num_threads (argc)) // expected-warning {{extra tokens at the end of '… in tmain()
26 …#pragma omp target parallel num_threads ((argc > 0) ? argv[1] : argv[2]) // expected-error 2 {{exp… in tmain()
28 …#pragma omp target parallel num_threads (foobool(argc)), num_threads (true), num_threads (-5) // e… in tmain()
30 #pragma omp target parallel num_threads (S) // expected-error {{'S' does not refer to a value}} in tmain()
32 …#pragma omp target parallel num_threads (argv[1]=2) // expected-error {{expected ')'}} expected-no… in tmain()
[all …]
|
| D | parallel_for_num_threads_messages.cpp | 15 #pragma omp parallel for num_threads // expected-error {{expected '(' after 'num_threads'}} in tmain()
17 …#pragma omp parallel for num_threads ( // expected-error {{expected expression}} expected-error {{… in tmain()
19 #pragma omp parallel for num_threads () // expected-error {{expected expression}} in tmain()
21 …#pragma omp parallel for num_threads (argc // expected-error {{expected ')'}} expected-note {{to m… in tmain()
23 …#pragma omp parallel for num_threads (argc)) // expected-warning {{extra tokens at the end of '#pr… in tmain()
25 …#pragma omp parallel for num_threads ((argc > 0) ? argv[1] : argv[2]) // expected-error 2 {{expres… in tmain()
27 …#pragma omp parallel for num_threads (foobool(argc)), num_threads (true), num_threads (-5) // expe… in tmain()
29 #pragma omp parallel for num_threads (S) // expected-error {{'S' does not refer to a value}} in tmain()
31 …#pragma omp parallel for num_threads (argv[1]=2) // expected-error {{expected ')'}} expected-note … in tmain()
33 #pragma omp parallel for num_threads (argc) in tmain()
[all …]
|
| D | parallel_for_simd_num_threads_messages.cpp | 15 #pragma omp parallel for simd num_threads // expected-error {{expected '(' after 'num_threads'}} in tmain()
17 …#pragma omp parallel for simd num_threads ( // expected-error {{expected expression}} expected-err… in tmain()
19 #pragma omp parallel for simd num_threads () // expected-error {{expected expression}} in tmain()
21 …#pragma omp parallel for simd num_threads (argc // expected-error {{expected ')'}} expected-note {… in tmain()
23 …#pragma omp parallel for simd num_threads (argc)) // expected-warning {{extra tokens at the end of… in tmain()
25 …#pragma omp parallel for simd num_threads ((argc > 0) ? argv[1] : argv[2]) // expected-error 2 {{e… in tmain()
27 …#pragma omp parallel for simd num_threads (foobool(argc)), num_threads (true), num_threads (-5) //… in tmain()
29 #pragma omp parallel for simd num_threads (S) // expected-error {{'S' does not refer to a value}} in tmain()
31 …#pragma omp parallel for simd num_threads (argv[1]=2) // expected-error {{expected ')'}} expected-… in tmain()
33 #pragma omp parallel for simd num_threads (argc) in tmain()
[all …]
|
| D | target_parallel_for_num_threads_messages.cpp | 15 #pragma omp target parallel for num_threads // expected-error {{expected '(' after 'num_threads'}} in tmain()
17 …#pragma omp target parallel for num_threads ( // expected-error {{expected expression}} expected-e… in tmain()
19 #pragma omp target parallel for num_threads () // expected-error {{expected expression}} in tmain()
21 …#pragma omp target parallel for num_threads (argc // expected-error {{expected ')'}} expected-note… in tmain()
23 …#pragma omp target parallel for num_threads (argc)) // expected-warning {{extra tokens at the end … in tmain()
25 …#pragma omp target parallel for num_threads ((argc > 0) ? argv[1] : argv[2]) // expected-error 2 {… in tmain()
27 …#pragma omp target parallel for num_threads (foobool(argc)), num_threads (true), num_threads (-5) … in tmain()
29 …#pragma omp target parallel for num_threads (S) // expected-error {{'S' does not refer to a value}} in tmain()
31 …#pragma omp target parallel for num_threads (argv[1]=2) // expected-error {{expected ')'}} expecte… in tmain()
33 #pragma omp target parallel for num_threads (argc) in tmain()
[all …]
|
| D | target_parallel_for_simd_num_threads_messages.cpp | 15 …#pragma omp target parallel for simd num_threads // expected-error {{expected '(' after 'num_threa… in tmain()
17 …#pragma omp target parallel for simd num_threads ( // expected-error {{expected expression}} expec… in tmain()
19 #pragma omp target parallel for simd num_threads () // expected-error {{expected expression}} in tmain()
21 …#pragma omp target parallel for simd num_threads (argc // expected-error {{expected ')'}} expected… in tmain()
23 …#pragma omp target parallel for simd num_threads (argc)) // expected-warning {{extra tokens at the… in tmain()
25 …#pragma omp target parallel for simd num_threads ((argc > 0) ? argv[1] : argv[2]) // expected-erro… in tmain()
27 …#pragma omp target parallel for simd num_threads (foobool(argc)), num_threads (true), num_threads … in tmain()
29 …#pragma omp target parallel for simd num_threads (S) // expected-error {{'S' does not refer to a v… in tmain()
31 …#pragma omp target parallel for simd num_threads (argv[1]=2) // expected-error {{expected ')'}} ex… in tmain()
33 #pragma omp target parallel for simd num_threads (argc) in tmain()
[all …]
|
| D | distribute_parallel_for_num_threads_messages.cpp | 17 #pragma omp distribute parallel for num_threads // expected-error {{expected '(' after 'num_threads… in tmain()
21 #pragma omp distribute parallel for num_threads ( // expected-error {{expected expression}} expecte… in tmain()
25 #pragma omp distribute parallel for num_threads () // expected-error {{expected expression}} in tmain()
29 #pragma omp distribute parallel for num_threads (argc // expected-error {{expected ')'}} expected-n… in tmain()
33 #pragma omp distribute parallel for num_threads (argc)) // expected-warning {{extra tokens at the e… in tmain()
37 #pragma omp distribute parallel for num_threads ((argc > 0) ? argv[1] : argv[2]) // expected-error … in tmain()
41 #pragma omp distribute parallel for num_threads (foobool(argc)), num_threads (true), num_threads (-… in tmain()
45 #pragma omp distribute parallel for num_threads (S) // expected-error {{'S' does not refer to a val… in tmain()
49 #pragma omp distribute parallel for num_threads (argv[1]=2) // expected-error {{expected ')'}} expe… in tmain()
53 #pragma omp distribute parallel for num_threads (argc) in tmain()
[all …]
|
| D | distribute_parallel_for_simd_num_threads_messages.cpp | 17 #pragma omp distribute parallel for simd num_threads // expected-error {{expected '(' after 'num_th… in tmain()
21 #pragma omp distribute parallel for simd num_threads ( // expected-error {{expected expression}} ex… in tmain()
25 #pragma omp distribute parallel for simd num_threads () // expected-error {{expected expression}} in tmain()
29 #pragma omp distribute parallel for simd num_threads (argc // expected-error {{expected ')'}} expec… in tmain()
33 #pragma omp distribute parallel for simd num_threads (argc)) // expected-warning {{extra tokens at … in tmain()
37 #pragma omp distribute parallel for simd num_threads ((argc > 0) ? argv[1] : argv[2]) // expected-e… in tmain()
41 #pragma omp distribute parallel for simd num_threads (foobool(argc)), num_threads (true), num_threa… in tmain()
45 #pragma omp distribute parallel for simd num_threads (S) // expected-error {{'S' does not refer to … in tmain()
49 #pragma omp distribute parallel for simd num_threads (argv[1]=2) // expected-error {{expected ')'}}… in tmain()
53 #pragma omp distribute parallel for simd num_threads (argc) in tmain()
[all …]
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| D | threadpool_test.cc | 35 for (int num_threads = 1; num_threads < kNumThreads; num_threads++) { in TEST() local
36 fprintf(stderr, "Testing with %d threads\n", num_threads); in TEST()
37 ThreadPool pool(Env::Default(), "test", num_threads); in TEST()
43 for (int num_threads = 1; num_threads < kNumThreads; num_threads++) { in TEST() local
44 fprintf(stderr, "Testing with %d threads\n", num_threads); in TEST()
51 ThreadPool pool(Env::Default(), "test", num_threads); in TEST()
213 const int64_t num_threads = threads->NumThreads(); in RunFixedBlockSizeShardingWithWorkerId() local
214 std::vector<std::atomic<bool>> threads_running(num_threads + 1); in RunFixedBlockSizeShardingWithWorkerId()
215 for (int i = 0; i < num_threads + 1; i++) { in RunFixedBlockSizeShardingWithWorkerId()
233 EXPECT_LE(id, num_threads); in RunFixedBlockSizeShardingWithWorkerId()
[all …]
|
| /external/cronet/tot/third_party/apache-portable-runtime/src/test/ |
| D | testlockperf.c | 47 apr_status_t test_thread_mutex(int num_threads); /* apr_thread_mutex_t */
51 apr_status_t test_thread_rwlock(int num_threads); /* apr_thread_rwlock_t */
53 int test_thread_mutex_nested(int num_threads);
82 int test_thread_mutex(int num_threads) in test_thread_mutex() argument
102 printf(" Starting %d threads ", num_threads); in test_thread_mutex()
103 for (i = 0; i < num_threads; ++i) { in test_thread_mutex()
116 for (i = 0; i < num_threads; ++i) { in test_thread_mutex()
124 if (mutex_counter != max_counter * num_threads) in test_thread_mutex()
130 int test_thread_mutex_nested(int num_threads) in test_thread_mutex_nested() argument
150 printf(" Starting %d threads ", num_threads); in test_thread_mutex_nested()
[all …]
|
| /external/cronet/stable/third_party/apache-portable-runtime/src/test/ |
| D | testlockperf.c | 47 apr_status_t test_thread_mutex(int num_threads); /* apr_thread_mutex_t */
51 apr_status_t test_thread_rwlock(int num_threads); /* apr_thread_rwlock_t */
53 int test_thread_mutex_nested(int num_threads);
82 int test_thread_mutex(int num_threads) in test_thread_mutex() argument
102 printf(" Starting %d threads ", num_threads); in test_thread_mutex()
103 for (i = 0; i < num_threads; ++i) { in test_thread_mutex()
116 for (i = 0; i < num_threads; ++i) { in test_thread_mutex()
124 if (mutex_counter != max_counter * num_threads) in test_thread_mutex()
130 int test_thread_mutex_nested(int num_threads) in test_thread_mutex_nested() argument
150 printf(" Starting %d threads ", num_threads); in test_thread_mutex_nested()
[all …]
|
| /external/compiler-rt/test/lsan/TestCases/ |
| D | high_allocator_contention.cc | 11 int num_threads; variable
24 for (int i = 0; i < total_num_alloc / num_threads; i++) { in thread_fun()
34 num_threads = atoi(argv[1]); in main()
35 assert(num_threads > 0); in main()
36 assert(num_threads <= kMaxNumThreads); in main()
39 printf("%d threads, %d allocations in each\n", num_threads, in main()
40 total_num_alloc / num_threads); in main()
41 for (int i = 0; i < num_threads; i++) in main()
47 for (int i = 0; i < num_threads; i++) pthread_join(tid[i], 0); in main()
|
| /external/mesa3d/src/util/ |
| D | u_queue.c | 274 while (thread_index < queue->num_threads && queue->num_queued == 0) in util_queue_thread_func()
278 if (thread_index >= queue->num_threads) { in util_queue_thread_func()
304 if (queue->num_threads == 0) { in util_queue_thread_func()
351 util_queue_adjust_num_threads(struct util_queue *queue, unsigned num_threads, in util_queue_adjust_num_threads() argument
354 num_threads = MIN2(num_threads, queue->max_threads); in util_queue_adjust_num_threads()
355 num_threads = MAX2(num_threads, 1); in util_queue_adjust_num_threads()
360 unsigned old_num_threads = queue->num_threads; in util_queue_adjust_num_threads()
362 if (num_threads == old_num_threads) { in util_queue_adjust_num_threads()
368 if (num_threads < old_num_threads) { in util_queue_adjust_num_threads()
369 util_queue_kill_threads(queue, num_threads, true); in util_queue_adjust_num_threads()
[all …]
|
| /external/igt-gpu-tools/tests/i915/ |
| D | gem_flink_race.c | 84 int r, i, num_threads; in test_flink_name() local
90 num_threads = sysconf(_SC_NPROCESSORS_ONLN) - 1; in test_flink_name()
91 if (!num_threads) in test_flink_name()
92 num_threads = 1; in test_flink_name()
94 threads = calloc(num_threads, sizeof(*threads)); in test_flink_name()
98 for (i = 0; i < num_threads; i++) { in test_flink_name()
118 for (i = 0; i < num_threads; i++) { in test_flink_name()
155 int r, i, num_threads; in test_flink_close() local
166 num_threads = sysconf(_SC_NPROCESSORS_ONLN); in test_flink_close()
168 threads = calloc(num_threads, sizeof(pthread_t)); in test_flink_close()
[all …]
|
| /external/tensorflow/tensorflow/lite/kernels/ |
| D | eigen_support.cc | 34 bool IsValidNumThreads(int num_threads) { return num_threads >= -1; } in IsValidNumThreads() argument
35 int GetNumThreads(int num_threads) { in GetNumThreads() argument
36 return num_threads > -1 ? num_threads : kDefaultNumThreadpoolThreads; in GetNumThreads()
68 explicit EigenThreadPoolWrapper(int num_threads) { in EigenThreadPoolWrapper() argument
70 if (num_threads > 1) { in EigenThreadPoolWrapper()
71 pool_ = std::make_unique<Eigen::ThreadPool>(num_threads); in EigenThreadPoolWrapper()
96 explicit LazyEigenThreadPoolHolder(int num_threads) { in LazyEigenThreadPoolHolder() argument
97 SetNumThreads(num_threads); in LazyEigenThreadPoolHolder()
112 void SetNumThreads(int num_threads) { in SetNumThreads() argument
113 const int target_num_threads = GetNumThreads(num_threads); in SetNumThreads()
|
| /external/tensorflow/tensorflow/lite/ |
| D | tflite_with_xnnpack_optional.cc | 32 TfLiteDelegatePtr MaybeCreateXNNPACKDelegate(int num_threads) { in MaybeCreateXNNPACKDelegate() argument
35 opts.num_threads = num_threads > 1 ? num_threads : 0; in MaybeCreateXNNPACKDelegate()
44 AcquireXNNPACKDelegate(int num_threads) { in AcquireXNNPACKDelegate() argument
48 TfLiteDelegatePtr MaybeCreateXNNPACKDelegate(int num_threads) { in MaybeCreateXNNPACKDelegate() argument
49 return AcquireXNNPACKDelegate(num_threads); in MaybeCreateXNNPACKDelegate()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | run_handler_util.cc | 79 void ComputeInterOpSchedulingRanges(int num_active_requests, int num_threads, in ComputeInterOpSchedulingRanges() argument
86 float demand_factor = static_cast<float>(num_threads) / total_weight; in ComputeInterOpSchedulingRanges()
105 int end = std::min(num_threads, start + demand); in ComputeInterOpSchedulingRanges()
113 void ComputeInterOpStealingRanges(int num_threads, int min_threads_per_domain, in ComputeInterOpStealingRanges() argument
116 int steal_domain_size = std::min(min_threads_per_domain, num_threads); in ComputeInterOpStealingRanges()
118 for (int i = 0; i < num_threads; ++i) { in ComputeInterOpStealingRanges()
120 if (steal_end + steal_domain_size < num_threads) { in ComputeInterOpStealingRanges()
124 steal_end = num_threads; in ComputeInterOpStealingRanges()
134 int num_active_requests, int num_threads) { in ChooseRequestsWithExponentialDistribution() argument
155 request_idx_list.resize(num_threads); in ChooseRequestsWithExponentialDistribution()
[all …]
|
| D | run_handler_util_test.cc | 27 void VerifySchedulingRanges(int num_active_requests, int num_threads, in VerifySchedulingRanges() argument
32 << " num_threads: " << num_threads in VerifySchedulingRanges()
38 ComputeInterOpSchedulingRanges(num_active_requests, num_threads, in VerifySchedulingRanges()
46 ASSERT_LE(end[i], num_threads) << range_str; in VerifySchedulingRanges()
60 float thread_demand = (entry_weight * num_threads) / total_weight; in VerifySchedulingRanges()
69 ASSERT_EQ(end[num_active_requests - 1], num_threads); in VerifySchedulingRanges()
86 for (int num_threads = min_threads_per_request; in TEST() local
87 num_threads <= kMaxThreads; ++num_threads) { in TEST()
88 VerifySchedulingRanges(num_active_requests, num_threads, in TEST()
120 int num_threads = 10; in TEST() local
[all …]
|
| /external/libvpx/test/ |
| D | vp9_skip_loopfilter_test.cc | 37 bool Init(int num_threads) { in Init() argument
49 if (num_threads > 0) cfg.threads = num_threads; in Init()
131 const int num_threads = 0; in TEST() local
133 ASSERT_TRUE(skip_loop_filter.Init(num_threads)); in TEST()
141 const int num_threads = 1; in TEST() local
143 ASSERT_TRUE(skip_loop_filter.Init(num_threads)); in TEST()
151 const int num_threads = 8; in TEST() local
153 ASSERT_TRUE(skip_loop_filter.Init(num_threads)); in TEST()
161 const int num_threads = 0; in TEST() local
163 ASSERT_TRUE(skip_loop_filter.Init(num_threads)); in TEST()
[all …]
|
| /external/bazelbuild-rules_rust/wasm_bindgen/3rdparty/crates/ |
| D | BUILD.time-0.3.23.bazel | 92 "@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # aarch64-apple-darwin
96 "@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # aarch64-apple-ios
100 "@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # aarch64-apple-ios-sim
104 "@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # aarch64-fuchsia
108 "@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # aarch64-linux-android
112 … "@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # aarch64-unknown-linux-gnu
116 …"@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # aarch64-unknown-linux-gnu, aarch64…
120 … "@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # aarch64-unknown-nto-qnx710
124 … "@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # arm-unknown-linux-gnueabi
128 "@rules_rust_wasm_bindgen__num_threads-0.1.6//:num_threads", # armv7-linux-androideabi
[all …]
|
| /external/bazelbuild-rules_rust/crate_universe/3rdparty/crates/ |
| D | BUILD.time-0.3.36.bazel | 101 "@cui__num_threads-0.1.6//:num_threads", # aarch64-apple-darwin
105 "@cui__num_threads-0.1.6//:num_threads", # aarch64-apple-ios
109 "@cui__num_threads-0.1.6//:num_threads", # aarch64-apple-ios-sim
113 "@cui__num_threads-0.1.6//:num_threads", # aarch64-fuchsia
117 "@cui__num_threads-0.1.6//:num_threads", # aarch64-linux-android
121 "@cui__num_threads-0.1.6//:num_threads", # aarch64-unknown-linux-gnu
125 … "@cui__num_threads-0.1.6//:num_threads", # aarch64-unknown-linux-gnu, aarch64-unknown-nixos-gnu
129 "@cui__num_threads-0.1.6//:num_threads", # aarch64-unknown-nto-qnx710
133 "@cui__num_threads-0.1.6//:num_threads", # arm-unknown-linux-gnueabi
137 "@cui__num_threads-0.1.6//:num_threads", # armv7-linux-androideabi
[all …]
|
| /external/ComputeLibrary/src/runtime/OMP/ |
| D | OMPScheduler.cpp | 39 unsigned int OMPScheduler::num_threads() const in num_threads() function in arm_compute::OMPScheduler
44 void OMPScheduler::set_num_threads(unsigned int num_threads) in set_num_threads() argument
47 _num_threads = (num_threads == 0) ? num_cores : num_threads; in set_num_threads()
64 const unsigned int num_threads = std::min(num_iterations, _num_threads); in schedule_op() local
66 if(!kernel->is_parallelisable() || num_threads == 1) in schedule_op()
74 const unsigned int num_windows = num_threads; in schedule_op()
101 info.num_threads = num_threads_to_use; in run_workloads()
102 #pragma omp parallel for firstprivate(info) num_threads(num_threads_to_use) default(shared) proc_bi… in run_workloads()
|
| /external/eigen/unsupported/test/ |
| D | cxx11_tensor_thread_local.cpp | 37 int num_threads = internal::random<int>(4, 32); in test_simple_thread_local() local
38 Eigen::ThreadPool thread_pool(num_threads); in test_simple_thread_local()
39 Eigen::ThreadLocal<Counter, InitCounter> counter(num_threads, InitCounter()); in test_simple_thread_local()
41 int num_tasks = 3 * num_threads; in test_simple_thread_local()
77 int num_threads = internal::random<int>(4, 32); in test_large_number_of_tasks_no_spill() local
78 Eigen::ThreadPool thread_pool(num_threads); in test_large_number_of_tasks_no_spill()
79 Eigen::ThreadLocal<Counter, InitCounter> counter(num_threads, InitCounter()); in test_large_number_of_tasks_no_spill()
106 unique_threads.size() <= (static_cast<size_t>(num_threads + 1)), true); in test_large_number_of_tasks_no_spill()
112 int num_threads = internal::random<int>(4, 32); in test_large_number_of_tasks_with_spill() local
113 Eigen::ThreadPool thread_pool(num_threads); in test_large_number_of_tasks_with_spill()
[all …]
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/resource_quota/ |
| D | thread_quota.cc | 32 bool ThreadQuota::Reserve(size_t num_threads) { in Reserve() argument
34 if (allocated_ + num_threads > max_) return false; in Reserve()
35 allocated_ += num_threads; in Reserve()
39 void ThreadQuota::Release(size_t num_threads) { in Release() argument
41 GPR_ASSERT(num_threads <= allocated_); in Release()
42 allocated_ -= num_threads; in Release()
|