Home
last modified time | relevance | path

Searched refs:wait_context (Results 1 – 17 of 17) sorted by relevance

/oneTBB/include/oneapi/tbb/detail/
H A D_task.h43 class wait_context; variable
52 …FUNC execute_and_wait(d1::task& t, d1::task_group_context& t_ctx, d1::wait_context&, d1::task_grou…
53 TBB_EXPORT void __TBB_EXPORTED_FUNC wait(d1::wait_context&, d1::task_group_context& ctx);
98 class wait_context {
134 …wait_context(std::uint32_t ref_count) : m_ref_count{ref_count} { suppress_unused_warning(m_version… in wait_context() function
135 wait_context(const wait_context&) = delete;
137 ~wait_context() { in ~wait_context()
190 inline void execute_and_wait(task& t, task_group_context& t_ctx, wait_context& wait_ctx, task_group… in execute_and_wait()
196 inline void wait(wait_context& wait_ctx, task_group_context& ctx) { in wait()
H A D_task_handle.h30 namespace d1 { class task_group_context; class wait_context; struct execution_data; } variable
37 d1::wait_context& m_wait_ctx;
49 …task_handle_task(d1::wait_context& wo, d1::task_group_context& ctx, d1::small_object_allocator& al… in task_handle_task()
H A D_flow_graph_impl.h335 wait_context my_wait_context;
/oneTBB/include/oneapi/tbb/
H A Dparallel_invoke.h68 wait_context& root_wait_ctx;
79 …invoke_subroot_task(const F1& f1, const F2& f2, const F3& f3, wait_context& wait_ctx, task_group_c… in invoke_subroot_task()
128 invoke_root_task(wait_context& wc) : my_wait_context(wc) {} in invoke_root_task()
133 wait_context& my_wait_context;
137 void invoke_recursive_separation(wait_context& root_wait_ctx, task_group_context& context, const F1… in invoke_recursive_separation()
146 void invoke_recursive_separation(wait_context& root_wait_ctx, task_group_context& context, const F1… in invoke_recursive_separation()
157 void invoke_recursive_separation(wait_context& root_wait_ctx, task_group_context& context, const F1… in invoke_recursive_separation()
171 void invoke_recursive_separation(wait_context& root_wait_ctx, task_group_context& context, in invoke_recursive_separation()
183 wait_context root_wait_ctx{0}; in parallel_invoke_impl()
192 wait_context root_wait_ctx{0}; in parallel_invoke_impl()
H A Dparallel_for_each.h196 feeder_impl(const Body& body, wait_context& w_context, task_group_context &context) in feeder_impl()
203 wait_context& my_wait_context;
213 …nput_item_ptr, const Body& body, feeder_impl<Body, Item>* feeder_ptr, wait_context& wait_context) : in for_each_iteration_task()
235 wait_context& parent_wait_context;
314 wait_context my_wait_context;
315 wait_context& my_root_wait_context;
375 wait_context my_wait_context;
376 wait_context& my_root_wait_context;
459 feeder_holder( wait_context&, task_group_context&, const Body& ) {}
492 wait_context& my_wait_context;
[all …]
H A Dparallel_scan.h95 wait_context& m_wait_context;
99 final_sum( Body& body, wait_context& w_o, small_object_allocator& alloc ) : in final_sum()
183 wait_context& m_wait_context;
188 …sum_node( const Range range, bool left_is_final_, sum_node* parent, wait_context& w_o, small_objec… in sum_node()
293 wait_context& m_wait_context;
316 …t, final_sum_type** sum, sum_node_type& result_, finish_scan* parent, wait_context& w_o, small_obj… in finish_scan()
367 wait_context& m_wait_context;
410 …t Range& range, final_sum_type& body, const Partitioner& partitioner, wait_context& w_o, small_obj… in start_scan()
431 wait_context w_ctx{1}; in run()
H A Dtask_group.h100 …function_task(FF&& f, d1::wait_context& wo, d1::task_group_context& ctx, d1::small_object_allocato… in function_task()
437 wait_context& m_wait_ctx;
442 wait_context& wo = m_wait_ctx; in finalize()
461 function_task(const F& f, wait_context& wo, small_object_allocator& alloc) in function_task()
466 function_task(F&& f, wait_context& wo, small_object_allocator& alloc) in function_task()
475 wait_context& m_wait_ctx;
490 function_stack_task(const F& f, wait_context& wo) : m_func(f), m_wait_ctx(wo) {} in function_stack_task()
495 wait_context m_wait_ctx;
H A Dcollaborative_call_once.h42 wait_context m_wait_context{1}; in alignas()
H A Dpartitioner.h129 wait_context m_wait{1};
/oneTBB/src/tbb/
H A Dwaiters.h74 d1::wait_context* wait_ctx() { in wait_ctx()
123 external_waiter(arena& a, d1::wait_context& wo) in external_waiter()
145 d1::wait_context* wait_ctx() { in wait_ctx()
154 d1::wait_context& my_wait_ctx;
181 d1::wait_context* wait_ctx() { in wait_ctx()
H A Dtask_dispatcher.cpp119 …FUNC execute_and_wait(d1::task& t, d1::task_group_context& t_ctx, d1::wait_context& wait_ctx, d1::… in execute_and_wait()
124 void __TBB_EXPORTED_FUNC wait(d1::wait_context& wait_ctx, d1::task_group_context& w_ctx) { in wait()
153 void task_dispatcher::execute_and_wait(d1::task* t, d1::wait_context& wait_ctx, d1::task_group_cont… in execute_and_wait()
H A Dscheduler_common.h96 d1::wait_context* wait_ctx{};
534 …static void execute_and_wait(d1::task* t, d1::wait_context& wait_ctx, d1::task_group_context& w_ct… in alignas()
H A Darena.cpp697 d1::wait_context& m_wait_ctx;
730 delegated_task(d1::delegate_base& d, concurrent_monitor& s, d1::wait_context& wo) in delegated_task()
751 d1::wait_context wo(1); in execute()
H A Dparallel_pipeline.cpp87 d1::wait_context wait_ctx;
/oneTBB/test/tbb/
H A Dtest_task.cpp77 tbb::detail::d1::wait_context& my_wait;
96 tbb::detail::d1::wait_context wait(1); in test_cancellation_on_exception()
142 tbb::detail::d1::wait_context wait(1);
176 tbb::detail::d1::wait_context wait(threads_num);
264 tbb::detail::d1::wait_context wait(threads_num);
377 tbb::detail::d1::wait_context& my_wait;
397 tbb::detail::d1::wait_context wait(1); in __anon509d20bd0b02()
455 tbb::detail::d1::wait_context& my_wait;
511 tbb::detail::d1::wait_context wait{ 0 };
584 tbb::detail::d1::wait_context wait(task_number);
[all …]
H A Dtest_task_arena.cpp252 using wait_context = tbb::detail::d1::wait_context; typedef in MultipleMastersPart3
255 wait_context& myWait;
256 Runner(wait_context& w) : myWait(w) {} in Runner()
264 wait_context& myWait;
276 wait_context wait(0); in operator ()()
930 using wait_context = tbb::detail::d1::wait_context; typedef in TestIsolatedExecuteNS::TestEnqueueTask
936 wait_context& waiter;
1074 using wait_context = tbb::detail::d1::wait_context; typedef in TestMultipleWaitsArenaWait
1093 std::vector<wait_context*>& my_waiters;
1099 using wait_context = tbb::detail::d1::wait_context; typedef in TestMultipleWaitsThreadBody
[all …]
H A Dtest_scheduler_mix.cpp559 tbb::detail::d1::wait_context wctx{ 1 }; in do_it()