Lines Matching refs:n_threads
530 int n_threads = 4; in TestMandatoryConcurrency() local
536 utils::SpinBarrier barrier(n_threads); in TestMandatoryConcurrency()
537 utils::NativeParallelFor(n_threads, [&](int) { in TestMandatoryConcurrency()
555 } while (num_tasks < n_threads * 5); in TestMandatoryConcurrency()
1377 void TestArenaWorkersMigrationWithNumThreads(int n_threads = 0) { in TestArenaWorkersMigrationWithNumThreads() argument
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()
1397 tbb::global_control control(tbb::global_control::max_allowed_parallelism, n_threads); in TestArenaWorkersMigrationWithNumThreads()
1402 utils::SpinBarrier barrier(n_threads); in TestArenaWorkersMigrationWithNumThreads()