Searched refs:n_threads (Results 1 – 2 of 2) sorted by relevance
83 int n_threads = sem_init_cnt + extra_threads; in test_semaphore() local85 std::vector<int> max_vals(n_threads); in test_semaphore()86 std::vector<double> tot_times(n_threads); in test_semaphore()89 Body body(n_threads, n_iters, my_sem, max_vals, tot_times); in test_semaphore()92 utils::NativeParallelFor(n_threads, body); in test_semaphore()135 void test_binary_semaphore( int n_threads ) { in test_binary_semaphore() argument138 utils::NativeParallelFor(n_threads, AddOneBody); in test_binary_semaphore()139 …REQUIRE_MESSAGE(n_threads * N_TIMES == counter.value, "Binary semaphore operations P()/V() have a … in test_binary_semaphore()
530 int n_threads = 4; in TestMandatoryConcurrency() local536 utils::SpinBarrier barrier(n_threads); in TestMandatoryConcurrency()537 utils::NativeParallelFor(n_threads, [&](int) { in TestMandatoryConcurrency()555 } while (num_tasks < n_threads * 5); in TestMandatoryConcurrency()1378 if (n_threads == 0) { in TestArenaWorkersMigrationWithNumThreads()1379 n_threads = tbb::this_task_arena::max_concurrency(); in TestArenaWorkersMigrationWithNumThreads()1384 if(n_threads > 16) { in TestArenaWorkersMigrationWithNumThreads()1386 } else if (n_threads > 8) { in TestArenaWorkersMigrationWithNumThreads()1390 int n_workers = n_threads - 1; in TestArenaWorkersMigrationWithNumThreads()1396 n_threads = n_workers + 1; in TestArenaWorkersMigrationWithNumThreads()[all …]