Home
last modified time | relevance | path

Searched refs:wait_ctx (Results 1 – 7 of 7) sorted by relevance

/oneTBB/include/oneapi/tbb/detail/
H A D_task.h190 inline void execute_and_wait(task& t, task_group_context& t_ctx, wait_context& wait_ctx, task_group… in execute_and_wait() argument
191 r1::execute_and_wait(t, t_ctx, wait_ctx, w_ctx); in execute_and_wait()
192 call_itt_task_notify(acquired, &wait_ctx); in execute_and_wait()
193 call_itt_task_notify(destroy, &wait_ctx); in execute_and_wait()
196 inline void wait(wait_context& wait_ctx, task_group_context& ctx) { in wait() argument
197 r1::wait(wait_ctx, ctx); in wait()
198 call_itt_task_notify(acquired, &wait_ctx); in wait()
199 call_itt_task_notify(destroy, &wait_ctx); in wait()
/oneTBB/src/tbb/
H A Dtask_dispatcher.cpp119 …_and_wait(d1::task& t, d1::task_group_context& t_ctx, d1::wait_context& wait_ctx, d1::task_group_c… in execute_and_wait() argument
121 task_dispatcher::execute_and_wait(&t, wait_ctx, w_ctx); in execute_and_wait()
124 void __TBB_EXPORTED_FUNC wait(d1::wait_context& wait_ctx, d1::task_group_context& w_ctx) { in wait() argument
126 task_dispatcher::execute_and_wait(nullptr, wait_ctx, 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() argument
167 external_waiter waiter{ *tls->my_arena, wait_ctx }; in execute_and_wait()
H A Dparallel_pipeline.cpp47 wait_ctx(0) { in pipeline()
87 d1::wait_context wait_ctx; member in tbb::detail::r1::pipeline
300 my_pipeline.wait_ctx.reserve(); in stage_task()
310 my_pipeline.wait_ctx.reserve(); in stage_task()
339 my_pipeline.wait_ctx.release(); in ~stage_task()
455 r1::execute_and_wait(st, cxt, pipe.wait_ctx, cxt); in parallel_pipeline()
H A Dwaiters.h74 d1::wait_context* wait_ctx() { in wait_ctx() function
145 d1::wait_context* wait_ctx() { in wait_ctx() function
181 d1::wait_context* wait_ctx() { in wait_ctx() function
H A Dtask_dispatcher.h68 if (ed_ext.wait_ctx) { in execute()
69 …thread_control_monitor::resume_context monitor_node{{std::uintptr_t(ed_ext.wait_ctx), nullptr}, ed… in execute()
77 if (wait_list.wait([&] { return !ed_ext.wait_ctx->continue_execution(); }, monitor_node)) { in execute()
280 ed.wait_ctx = waiter.wait_ctx(); in local_wait_for_all()
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()
/oneTBB/include/oneapi/tbb/
H A Dparallel_invoke.h40 function_invoker(const Function& function, WaitObject& wait_ctx) : in function_invoker()
42 parent_wait_ctx(wait_ctx) in function_invoker()
79 …invoke_subroot_task(const F1& f1, const F2& f2, const F3& f3, wait_context& wait_ctx, task_group_c… in invoke_subroot_task()
81 root_wait_ctx(wait_ctx), in invoke_subroot_task()