Lines Matching refs:barrier

201     utils::SpinBarrier barrier(2);  in TestConcurrentArenasFunc()  local
202 AsynchronousWork work(barrier); in TestConcurrentArenasFunc()
205 barrier.wait(); in TestConcurrentArenasFunc()
301 utils::SpinBarrier barrier(p+2); in TestMultipleMasters() local
302 …a.enqueue(AsynchronousWork(barrier, /*blocking=*/true)); // occupy the worker, a regression test f… in TestMultipleMasters()
305 NativeParallelFor( p, MultipleMastersPart2(a, barrier) ); in TestMultipleMasters()
306 barrier.wait(); in TestMultipleMasters()
311 …utils::SpinBarrier barrier(p+1); // for external threads to avoid endless waiting at least in some… in TestMultipleMasters() local
313 NativeParallelFor( p+1, MultipleMastersPart3(a, barrier) ); in TestMultipleMasters()
513 TestMandatoryConcurrencyObserver(tbb::task_arena& a, utils::SpinBarrier& barrier) in TestMandatoryConcurrencyObserver()
514 : tbb::task_scheduler_observer(a), m_barrier(barrier) { in TestMandatoryConcurrencyObserver()
536 utils::SpinBarrier barrier(n_threads); in TestMandatoryConcurrency() local
539 barrier.wait(); in TestMandatoryConcurrency()
550 barrier.wait(); in TestMandatoryConcurrency()
1350 utils::SpinBarrier& barrier) in MyObserver()
1352 my_failure_counter(failure_counter), my_counter(counter), m_barrier(barrier) { in MyObserver()
1402 utils::SpinBarrier barrier(n_threads); in TestArenaWorkersMigrationWithNumThreads() local
1412 observer[i] = new MyObserver(arenas[i], tls, failure_counter, counter, barrier); in TestArenaWorkersMigrationWithNumThreads()
1424 barrier.wait(); // entry in TestArenaWorkersMigrationWithNumThreads()
1425 barrier.wait(); // exit1 in TestArenaWorkersMigrationWithNumThreads()
1427 barrier.wait(); // exit2 in TestArenaWorkersMigrationWithNumThreads()
1429 barrier.wait(); // entry in TestArenaWorkersMigrationWithNumThreads()
1430 barrier.wait(); // exit1 in TestArenaWorkersMigrationWithNumThreads()
1431 barrier.wait(); // exit2 in TestArenaWorkersMigrationWithNumThreads()
1468 utils::SpinBarrier barrier(threads); in TestDefaultCreatedWorkersAmount() local
1472 tbb::parallel_for(0, threads, [threads, blocked, &barrier](int) { in TestDefaultCreatedWorkersAmount()
1479 barrier.wait(); in TestDefaultCreatedWorkersAmount()
1774 utils::SpinBarrier barrier( concurrency - reserved_slots + 1 ); in test_threads_sleep() local
1784 barrier.signalNoWait(); in test_threads_sleep()
1801 barrier.wait(); in test_threads_sleep()
1951 utils::SpinBarrier barrier(num_threads * 2); variable
1957 barrier.wait(); in __anon1d1198c32002()
1975 barrier.wait(); in __anon1d1198c32202()