| /oneTBB/test/tbb/ |
| H A D | test_task.cpp | 52 CountingTask( tbb::detail::d1::wait_context& wait ) : my_wait(wait) {} in CountingTask() argument
115 wait.release(1); in test_cancellation_on_exception()
135 barrier.wait();
137 test_gr.wait();
187 tbb::detail::d1::wait(wait, test_context);
237 tbb::detail::d1::wait(wait, test_context);
408 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd0b02()
575 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd1602()
620 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd1902()
715 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd1f02()
[all …]
|
| H A D | test_task_group.cpp | 331 tg.wait(); in impl()
366 tg.wait(); in TestFibWithLambdas()
383 tg.wait(); in TestFibWithFunctionPtr()
479 g.wait(); in LaunchChildrenWithFunctor()
519 tg.wait(); in TestExceptionHandling1()
537 tg.wait(); in TestExceptionHandling2()
676 tg.wait(); in TestBareFunctors()
679 tg.wait(); in TestBareFunctors()
920 tg2.wait();
1041 tg.wait();
[all …]
|
| H A D | test_collaborative_call_once.cpp | 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()
380 barrier.wait(); in __anon8532fc101102()
|
| H A D | test_task_arena.cpp | 205 barrier.wait(); in TestConcurrentArenasFunc()
233 my_b1.wait(); in operator ()()
276 wait_context wait(0); in operator ()() local
279 wait.reserve(); in operator ()()
283 my_b.wait(); in operator ()()
295 barrier2.wait(); in TestMultipleMasters()
306 barrier.wait(); in TestMultipleMasters()
522 m_barrier.wait(); in on_scheduler_exit()
1366 m_barrier.wait(); in on_scheduler_entry()
1651 thread_barrier.wait(); in StressTestMixFunctionality()
[all …]
|
| H A D | test_concurrent_monitor.cpp | 68 barrier.wait(); in __anon1eb8c3140102()
78 barrier.wait();
|
| H A D | test_semaphore.cpp | 60 sBarrier.wait(); in operator ()()
201 sBarrier.wait(); in Produce()
227 sBarrier.wait(); in Consume()
|
| H A D | test_flow_graph.cpp | 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 ()()
|
| H A D | test_resumable_tasks.cpp | 74 async->m_condvar.wait(lock, [async] {return !async->m_tagQueue.empty(); }); in asyncLoop()
222 async->m_condvar.wait(lock, [async] {return !async->m_tagQueue.empty(); }); in asyncLoop()
327 tg.wait(); in TestCleanupMaster()
361 tg.wait(); in TestNativeThread()
|
| /oneTBB/test/conformance/ |
| H A D | conformance_task_group.cpp | 63 tg.wait();
158 tg.wait(); in __anon0c2008c70702()
189 CHECK_THROWS_AS(tg.wait(), std::runtime_error);
207 void run_cancellation_use_case(CancelF&& cancel, WaitF&& wait) { in run_cancellation_use_case() argument
230 outer_status = std::forward<WaitF>(wait)(outer_tg); in run_cancellation_use_case()
236 tbb::task_group_status inner_status = inner_tg.wait(); in run_cancellation_use_case()
253 [](tbb::task_group& outer) { return outer.wait(); } in test()
266 outer.wait(); in test()
|
| H A D | conformance_global_control.cpp | 54 barr1->wait(); in operator ()()
57 barr2->wait(); in operator ()()
109 barr.wait(); in operator ()()
114 barr.wait(); in operator ()()
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 ()()
[all …]
|
| H A D | conformance_collaborative_call_once.cpp | 78 barrier.wait(); in __anon8e61f74e0302()
98 barrier.wait(); in __anon8e61f74e0402()
110 barrier.wait(); in __anon8e61f74e0602()
118 tg.wait();
|
| H A D | conformance_task_arena.cpp | 142 tg.wait();
163 tg.wait();
192 tg.wait();
213 CHECK_THROWS_AS(tg.wait(), std::runtime_error);
230 CHECK_THROWS_AS(tg.wait(), std::runtime_error);
|
| /oneTBB/python/tbb/ |
| H A D | api.i | 101 b.event.wait(lock);
104 b.event.wait(lock);
105 tg.wait();
134 void wait();
|
| H A D | pool.py | 221 self._tasks.wait()
344 if not self.wait(timeout):
350 def wait(self, timeout=None): member in ApplyResult
353 self._event.wait(timeout)
525 self._cond.wait(timeout=timeout)
596 res.wait(timeout)
|
| /oneTBB/test/tbbmalloc/ |
| H A D | test_malloc_init_shutdown.cpp | 44 my_barr->wait(); in operator ()()
74 my_barr->wait(); in operator ()()
87 my_barr->wait(); in operator ()()
|
| H A D | test_malloc_used_by_lib.cpp | 102 startBarr.wait(); in operator ()()
104 endBarr.wait(unloadCallback); in operator ()()
|
| H A D | test_malloc_pools.cpp | 142 startB.wait(); in operator ()()
156 mallocDone.wait(); in operator ()()
264 barrier.wait(); in operator ()()
348 startB.wait(); in operator ()()
366 startB->wait(); in operator ()()
379 barrier->wait(); in operator ()()
382 barrier->wait(); in operator ()()
801 barrier->wait(); in operator ()()
809 barrier->wait(); in operator ()()
|
| H A D | test_malloc_whitebox.cpp | 147 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 …]
|
| /oneTBB/test/common/ |
| H A D | spin_barrier.h | 158 bool wait( const Callback& onOpenBarrierCallback ) { in wait() function
162 bool wait() { in wait() function
163 return wait(DummyCallback()); in wait()
|
| /oneTBB/src/tbb/ |
| H A D | concurrent_monitor_mutex.h | 55 wait(); in lock()
70 void wait() { in wait() function
|
| H A D | rml_thread_monitor.h | 92 void wait();
234 inline void thread_monitor::wait() { in wait() function
|
| H A D | concurrent_monitor.h | 119 virtual void wait() = 0;
167 void wait() override { in wait() function
232 node.wait(); in commit_wait()
259 bool wait(Pred&& pred, NodeType&& node) { in wait() function
|
| /oneTBB/doc/main/tbb_userguide/ |
| H A D | destroy_graphs_outside_main_thread.rst | 6 Make sure to enqueue a task to wait for and destroy graphs that run outside the main thread.
11 and wait for the graph to complete. For example, assume you really do
|
| /oneTBB/doc/main/tbb_userguide/Migration_Guide/ |
| H A D | Task_API.rst | 54 tg.wait();
191 tg.wait();
224 tg.wait();
256 tg.wait();
326 tg.wait();
384 tg.wait();
443 tg.wait();
452 …The call to ``oneapi::tbb::task_group::wait`` will not return control until both ``ChildTask`` and
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _task.h | 53 TBB_EXPORT void __TBB_EXPORTED_FUNC wait(d1::wait_context&, d1::task_group_context& ctx);
196 inline void wait(wait_context& wait_ctx, task_group_context& ctx) { in wait() function
197 r1::wait(wait_ctx, ctx); in wait()
|