Home
last modified time | relevance | path

Searched refs:barrier (Results 1 – 22 of 22) sorted by relevance

/oneTBB/test/conformance/
H A Dconformance_collaborative_call_once.cpp71 utils::SpinBarrier barrier{num_threads}; variable
78 barrier.wait(); in __anon8e61f74e0302()
91 utils::SpinBarrier barrier(num_threads);
97 tg.run([&flag, &barrier] { in __anon8e61f74e0402()
98 barrier.wait(); in __anon8e61f74e0402()
109 oneapi::tbb::collaborative_call_once(flag, [&barrier] { in __anon8e61f74e0602()
110 barrier.wait(); in __anon8e61f74e0602()
H A Dconformance_global_control.cpp148 utils::SpinBarrier &barrier; member in TestMultipleControlsRun
152 barrier.wait(); in operator ()()
157 barrier.wait(); in operator ()()
160 barrier.wait(); in operator ()()
164 barrier.wait(); in operator ()()
166 barrier.wait(); in operator ()()
172 barrier.wait(); in operator ()()
174 barrier.wait(); in operator ()()
176 barrier.wait(); in operator ()()
179 barrier.wait(); in operator ()()
[all …]
H A Dconformance_concurrent_hash_map.cpp832 utils::SpinBarrier& barrier; member
834 FakeExclusive(utils::SpinBarrier& b, YourTable&t) : barrier(b), table(t) {} in FakeExclusive()
840 barrier.wait(); // item can be erased in operator ()()
848 barrier.wait(); // readers acquired in operator ()()
953 utils::SpinBarrier barrier(nthread); in TestInsertFindErase() local
955 utils::NativeParallelFor( nthread, FakeExclusive(barrier, ie_table)); in TestInsertFindErase()
H A Dconformance_enumerable_thread_specific.cpp1218 utils::SpinBarrier barrier(LOCALS);
1220 barrier.wait(); in __anonba7ca1840402()
/oneTBB/test/tbb/
H A Dtest_flow_graph_priorities.cpp132 utils::SpinBarrier barrier( num_threads ); in test_node() local
265 ServiceThreadFunc(SpinBarrier& barrier) : my_barrier(barrier) {} in ServiceThreadFunc()
285 AsyncActivity(SpinBarrier& barrier) in AsyncActivity()
306 : my_barrier(barrier), my_input(input) {} in ParallelForBody()
367 AsyncActivity activity(barrier); in test()
745 std::atomic<int>& barrier; member
750 --barrier; in operator ()()
751 while (barrier) in operator ()()
754 std::atomic<int>& barrier; member
764 std::atomic<int> barrier; in test() local
[all …]
H A Dtest_collaborative_call_once.cpp235 utils::SpinBarrier barrier{N}; variable
240 barrier.wait([&] { in __anon8532fc100602()
336 barrier.wait(); in __anon8532fc100c02()
339 barrier.wait(); in __anon8532fc100c02()
355 barrier.wait(); in __anon8532fc100f02()
356 barrier.wait(); in __anon8532fc100f02()
362 barrier.wait(); in __anon8532fc100f02()
366 barrier.wait();
374 barrier.wait(); in __anon8532fc101102()
376 barrier.wait(); in __anon8532fc101102()
[all …]
H A Dtest_concurrent_monitor.cpp54 utils::SpinBarrier barrier(threads_number);
68 barrier.wait(); in __anon1eb8c3140102()
78 barrier.wait();
H A Dtest_task.cpp126 utils::SpinBarrier barrier(2); variable
131 barrier.wait(); in __anon509d20bd0202()
135 barrier.wait();
173 barrier.wait(); in __anon509d20bd0302()
203 barrier.wait(); in __anon509d20bd0402()
261 barrier.wait(); in __anon509d20bd0702()
640 barrier.wait(); in __anon509d20bd1a02()
645 barrier.wait(); in __anon509d20bd1a02()
653 barrier.wait();
654 barrier.wait();
[all …]
H A Dtest_task_arena.cpp201 utils::SpinBarrier barrier(2); in TestConcurrentArenasFunc() local
202 AsynchronousWork work(barrier); in TestConcurrentArenasFunc()
205 barrier.wait(); in TestConcurrentArenasFunc()
306 barrier.wait(); in TestMultipleMasters()
539 barrier.wait(); in TestMandatoryConcurrency()
1429 barrier.wait(); // entry in TestArenaWorkersMigrationWithNumThreads()
1430 barrier.wait(); // exit1 in TestArenaWorkersMigrationWithNumThreads()
1431 barrier.wait(); // exit2 in TestArenaWorkersMigrationWithNumThreads()
1801 barrier.wait(); in test_threads_sleep()
1957 barrier.wait(); in __anon1d1198c32002()
[all …]
H A Dtest_flow_graph.cpp122 utils::SpinBarrier &barrier; member in AddRemoveBody
125 g(_g), nThreads(nthr), barrier(barrier_) in AddRemoveBody()
131 barrier.wait(); // wait until all nodes are created in operator ()()
138 barrier.wait(); // wait until all threads are done counting in operator ()()
140 barrier.wait(); // wait until all threads have deleted all nodes in their vectors in operator ()()
147 barrier.wait(); // wait until all threads are done counting in operator ()()
153 utils::SpinBarrier barrier(nThreads); in test_parallel() local
154 AddRemoveBody body(nThreads, barrier, g); in test_parallel()
H A Dtest_arena_constraints.cpp113 utils::SpinBarrier barrier; in __anon2861f8e80202() local
114 barrier.initialize(tbb::this_task_arena::max_concurrency()); in __anon2861f8e80202()
117 [&barrier](const tbb::blocked_range<size_t>&) { in __anon2861f8e80202()
118 barrier.wait(); in __anon2861f8e80202()
H A Dtest_global_control.cpp164 Body( utils::SpinBarrier& barrier ) : myBarrier( barrier ) {} in Body() argument
177 utils::SpinBarrier barrier(numThreads); in operator ()() local
178 tbb::parallel_for(0, numThreads, Body(barrier)); in operator ()()
H A Dtest_arena_priorities.cpp140 void submit_work( std::vector<arena_info>& arenas, unsigned repeats, utils::SpinBarrier& barrier ) { in submit_work() argument
148 [repeats, &barrier, &tg, priority_value, concurrency]() { in submit_work()
151 [&barrier, priority_value](){ in submit_work()
155 barrier.wait(); in submit_work()
273 utils::SpinBarrier barrier{ max_num_threads }; in test() local
274 submit_work( arenas, repeats, barrier ); in test()
H A Dtest_partitioner.cpp138 utils::SpinBarrier barrier(2 * utils::get_platform_max_threads()); in strict_test() local
140 while (test(/*per body invocation call*/[&barrier] { barrier.wait(); }) > tolerance); in strict_test()
H A Dtest_task_group.cpp200 …RunAndWaitSyncronizationTestBody(utils::SpinBarrier& barrier, std::atomic<bool>& completed, task_g… in RunAndWaitSyncronizationTestBody() argument
201 : m_barrier(barrier), m_completed(completed), m_tg(tg) {} in RunAndWaitSyncronizationTestBody()
229 utils::SpinBarrier barrier(g_MaxConcurrency); in TestParallelWait() local
233 RunAndWaitSyncronizationTestBody<task_group_type> b(barrier, completed, tg); in TestParallelWait()
996 utils::SpinBarrier barrier(num_threads + 2); variable
1001 a.enqueue([i, &tg, &finished, &barrier] { in __anoneb262a490f02()
1002 barrier.wait(); in __anoneb262a490f02()
1011 barrier.wait(); in __anoneb262a491102()
H A Dtest_concurrent_vector.cpp441 utils::SpinBarrier barrier(threads_number); in TestConcurrentOperationsWithUnSafeOperations() local
442 …auto concurrent_func = [&operations, &vector, &curr_unsafe_thread, &barrier, &all_done, &active_th… in TestConcurrentOperationsWithUnSafeOperations()
460 barrier.wait(); in TestConcurrentOperationsWithUnSafeOperations()
461 barrier.wait(); in TestConcurrentOperationsWithUnSafeOperations()
489 barrier.wait(); in TestConcurrentOperationsWithUnSafeOperations()
508 barrier.wait(); in TestConcurrentOperationsWithUnSafeOperations()
H A Dtest_async_node.cpp617 body_graph_with_async( utils::SpinBarrier& barrier, async_activity_type& activity ) in body_graph_with_async() argument
618 : spin_barrier(&barrier), my_async_activity(&activity) {} in body_graph_with_async()
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_pools.cpp223 static utils::SpinBarrier barrier; member in CrossThreadRun
264 barrier.wait(); in operator ()()
373 utils::SpinBarrier *barrier; member in FixedPoolSomeMem
377 barrier(b), pool(p) {} in FixedPoolSomeMem()
379 barrier->wait(); in operator ()()
382 barrier->wait(); in operator ()()
432 utils::SpinBarrier barrier(p); in TestFixedBufferPool() local
795 utils::SpinBarrier *barrier; member in NoLeakOnDestroyRun
801 barrier->wait(); in operator ()()
809 barrier->wait(); in operator ()()
[all …]
H A Dtest_malloc_whitebox.cpp147 barrier.wait(); in operator ()()
195 barrier.wait(); in operator ()()
303 barrier.wait(); in operator ()()
645 barrier.wait(); in operator ()()
843 barrier.wait(); in operator ()()
845 barrier.wait(); in operator ()()
879 barrier.wait(); in operator ()()
881 barrier.wait(); in operator ()()
883 barrier.wait(); in operator ()()
1142 barrier.wait(); in operator ()()
[all …]
H A Dtest_malloc_compliance.cpp201 CMemTest(utils::SpinBarrier *barrier, bool isVerbose=false) : limitBarrier(barrier) in CMemTest() argument
1087 utils::SpinBarrier *barrier = new utils::SpinBarrier(p); variable
1088 utils::NativeParallelFor( p, RoundRobin(p, barrier, Verbose) );
1089 delete barrier;
/oneTBB/test/common/
H A Dconcurrency_tracker.h106 SpinBarrier barrier((unsigned)myConcLevel, /*throwaway=*/true); in run()
108 myBarrier = &barrier; in run()
H A Dgraph_utils.h742 native_loop_limited_body(NodeType& node, utils::SpinBarrier& barrier):
743 my_node(node), my_barrier(barrier) {}
806 utils::SpinBarrier barrier(N - concurrency);
807 utils::NativeParallelFor(N, native_loop_limited_body<NodeType>(node, barrier));
823 utils::SpinBarrier barrier(N);
824 utils::NativeParallelFor(N, native_loop_limited_body<NodeType>(node, barrier));