Searched refs:spin_barrier (Results 1 – 2 of 2) sorted by relevance
536 utils::SpinBarrier spin_barrier(nthreads); in run() local552 g, tbb::flow::unlimited, end_body_type(std::this_thread::get_id(), spin_barrier) in run()618 : spin_barrier(&barrier), my_async_activity(&activity) {} in body_graph_with_async()639 spin_barrier->wait(); in operator ()()647 utils::SpinBarrier* spin_barrier; member in enqueueing_on_inner_level::body_graph_with_async655 utils::SpinBarrier spin_barrier( nthreads ); in run() local659 tbb::parallel_for( 0, nthreads, body_graph_with_async( spin_barrier, my_async_activity ) ); in run()
307 utils::SpinBarrier spin_barrier(utils::min(concurrency_level, n_tokens), true);309 [&spin_barrier](int value)311 spin_barrier.wait(); in __anon5895f2ca0d02()