| /oneTBB/test/conformance/ |
| H A D | conformance_composite_node.cpp | 106 oneapi::tbb::flow::write_once_node<int> wo(g);
111 pq, ovw, wo, bf, seq);
113 q, pq, ovw, wo, bf, seq);
119 a_node.add_visible_nodes(src, fxn, m_fxn, bc, lim, ind, s, ct, j, q, bf, pq, wo, ovw, seq);
120 a_node.add_nodes(src, fxn, m_fxn, bc, lim, ind, s, ct, j, q, bf, pq, wo, ovw, seq);
134 b_node.add_visible_nodes(src, fxn, m_fxn, bc, lim, ind, s, ct, j, q, bf, pq, wo, ovw, seq);
135 b_node.add_nodes(src, fxn, m_fxn, bc, lim, ind, s, ct, j, q, bf, pq, wo, ovw, seq);
148 c_node.add_visible_nodes(src, fxn, m_fxn, bc, lim, ind, s, ct, j, q, bf, pq, wo, ovw, seq);
150 c_node.add_nodes(src, fxn, m_fxn, bc, lim, ind, s, ct, j, q, bf, pq, wo, ovw, seq);
|
| H A D | conformance_graph.cpp | 205 oneapi::tbb::flow::write_once_node<int> wo(g);
220 oneapi::tbb::flow::make_edge(wo, successor);
238 wo.try_put(1);
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | task_group.h | 100 …function_task(FF&& f, d1::wait_context& wo, d1::task_group_context& ctx, d1::small_object_allocato… in function_task() argument
101 : task_handle_task{wo, ctx, alloc}, in function_task()
442 wait_context& wo = m_wait_ctx; in finalize() local
447 wo.release(); in finalize()
461 function_task(const F& f, wait_context& wo, small_object_allocator& alloc) in function_task() argument
463 , m_wait_ctx(wo) in function_task()
466 function_task(F&& f, wait_context& wo, small_object_allocator& alloc) in function_task() argument
468 , m_wait_ctx(wo) in function_task()
490 function_stack_task(const F& f, wait_context& wo) : m_func(f), m_wait_ctx(wo) {} in function_stack_task() argument
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _task_handle.h | 49 …task_handle_task(d1::wait_context& wo, d1::task_group_context& ctx, d1::small_object_allocator& al… in task_handle_task() argument
50 : m_wait_ctx(wo) in task_handle_task()
|
| /oneTBB/src/tbb/ |
| H A D | waiters.h | 123 external_waiter(arena& a, d1::wait_context& wo) in external_waiter() argument
124 : sleep_waiter(a, /*yields_multiplier*/10), my_wait_ctx(wo) in external_waiter()
|
| H A D | arena.cpp | 730 delegated_task(d1::delegate_base& d, concurrent_monitor& s, d1::wait_context& wo) in delegated_task() argument
731 : m_delegate(d), m_monitor(s), m_wait_ctx(wo), m_completed{ false }{} in delegated_task()
751 d1::wait_context wo(1); in execute() local
755 delegated_task dt(d, a->my_exit_monitors, wo); in execute()
760 if (!wo.continue_execution()) { in execute()
768 r1::wait(wo, exec_context); in execute()
773 } while (wo.continue_execution()); in execute()
|