Home
last modified time | relevance | path

Searched refs:waiter (Results 1 – 6 of 6) sorted by relevance

/oneTBB/src/tbb/
H A Daddress_waiter.cpp70 address_waiter& waiter = get_address_waiter(address); in wait_on_address() local
71 waiter.wait<address_waiter::thread_context>(predicate, address_context{address, context}); in wait_on_address()
75 address_waiter& waiter = get_address_waiter(address); in notify_by_address() local
81 waiter.notify_relaxed(predicate); in notify_by_address()
85 address_waiter& waiter = get_address_waiter(address); in notify_by_address_one() local
91 waiter.notify_one_relaxed(predicate); in notify_by_address_one()
95 address_waiter& waiter = get_address_waiter(address); in notify_by_address_all() local
101 waiter.notify_relaxed(predicate); in notify_by_address_all()
H A Dtask_dispatcher.h172 thread_data& tls, execution_data_ext& ed, Waiter& waiter, isolation_type isolation, in receive_or_steal_task() argument
188 waiter.reset_wait(); in receive_or_steal_task()
199 if (!waiter.continue_execution(slot, t)) { in receive_or_steal_task()
232 waiter.pause(slot); in receive_or_steal_task()
243 d1::task* task_dispatcher::local_wait_for_all(d1::task* t, Waiter& waiter ) { in local_wait_for_all() argument
280 ed.wait_ctx = waiter.wait_ctx(); in local_wait_for_all()
340 if (!waiter.continue_execution(slot, t)) { in local_wait_for_all()
352 … *m_thread_data, ed, waiter, isolation, dl_guard.old_properties.fifo_tasks_allowed, in local_wait_for_all()
455 d1::task* task_dispatcher::local_wait_for_all(d1::task* t, Waiter& waiter) { in local_wait_for_all() argument
457 return local_wait_for_all</*ITTPossible = */ true>(t, waiter); in local_wait_for_all()
[all …]
H A Dtask_dispatcher.cpp167 external_waiter waiter{ *tls->my_arena, wait_ctx }; in execute_and_wait() local
168 t = local_td.local_wait_for_all(t, waiter); in execute_and_wait()
216 coroutine_waiter waiter(*a); in co_local_wait_for_all() local
217 resume_task = local_wait_for_all(nullptr, waiter); in co_local_wait_for_all()
H A Darena.cpp217 outermost_worker_waiter waiter(*this); in process() local
218 d1::task* t = tls.my_task_dispatcher->local_wait_for_all(nullptr, waiter); in process()
750 concurrent_monitor::thread_context waiter((std::uintptr_t)&d); in execute() local
759 a->my_exit_monitors.prepare_wait(waiter); in execute()
761 a->my_exit_monitors.cancel_wait(waiter); in execute()
766 a->my_exit_monitors.cancel_wait(waiter); in execute()
772 a->my_exit_monitors.commit_wait(waiter); in execute()
H A Dscheduler_common.h493 d1::task* receive_or_steal_task(thread_data& tls, execution_data_ext& ed, Waiter& waiter, in alignas()
497 d1::task* local_wait_for_all(d1::task * t, Waiter& waiter); in alignas()
515 d1::task* local_wait_for_all(d1::task* t, Waiter& waiter); in alignas()
/oneTBB/test/tbb/
H A Dtest_task_arena.cpp936 wait_context& waiter; member in TestIsolatedExecuteNS::TestEnqueueTask
941 : executed(exe), completed(c), waiter(w), arena(a) {} in TestEnqueueTask()
949 waiter.release(1); in execute()
968 tbb::detail::d1::wait_context waiter(N); in operator ()() local
970 TestEnqueueTask root(executed, completed, waiter, arena); in operator ()()
971 tbb::detail::d1::execute_and_wait(root, ctx, waiter, ctx); in operator ()()
995 tbb::detail::d1::wait_context waiter(N); in TestEnqueue() local
1001 waiter.release(1); in TestEnqueue()
1008 tbb::detail::d1::wait(waiter, ctx); in TestEnqueue()