Home
last modified time | relevance | path

Searched refs:enqueue (Results 1 – 22 of 22) sorted by relevance

/oneTBB/test/conformance/
H A Dconformance_task_arena.cpp42 a.enqueue([&done] { in __anon3e0b77410102()
141 arena.enqueue(std::move(task_handle));
160 oneapi::tbb::this_task_arena::enqueue(std::move(task_handle)); in __anon3e0b77410702()
185 oneapi::tbb::this_task_arena::enqueue([&]{ in __anon3e0b77410a02()
211 arena.enqueue(std::move(h));
228 oneapi::tbb::this_task_arena::enqueue(std::move(h));
H A Dconformance_arena_constraints.cpp36 arena.enqueue([&]{ task_done = true; }); in __anonb63cdda60202()
/oneTBB/doc/main/tbb_userguide/
H A Ddestroy_graphs_outside_main_thread.rst6 Make sure to enqueue a task to wait for and destroy graphs that run outside the main thread.
10 before destroying it. A common solution is to enqueue a task to build
13 Instead you can enqueue a task that creates the graph and waits for it:
34 a.enqueue(background_task());
/oneTBB/include/oneapi/tbb/
H A Dtask_arena.h95 TBB_EXPORT void __TBB_EXPORTED_FUNC enqueue(d1::task&, d1::task_arena_base*);
96 TBB_EXPORT void __TBB_EXPORTED_FUNC enqueue(d1::task&, d1::task_group_context&, d1::task_arena_base…
107 r1::enqueue(*task_handle_accessor::release(th), ctx, ta); in enqueue_impl()
233 …r1::enqueue(*alloc.new_object<enqueue_task<typename std::decay<F>::type>>(std::forward<F>(f), allo… in enqueue_impl()
386 void enqueue(F&& f) { in enqueue() function
393 void enqueue(d2::task_handle&& th) { in enqueue() function
466 inline void enqueue(d2::task_handle&& th) { in enqueue() function
471 inline void enqueue(F&& f) { in enqueue() function
493 using detail::d1::enqueue;
/oneTBB/test/tbb/
H A Dtest_task_arena.cpp204 a1.enqueue(work); // put async work in TestConcurrentArenasFunc()
207 a2.enqueue(work); // another work in TestConcurrentArenasFunc()
280 my_a.enqueue(Runner(wait)); in operator ()()
481 a.enqueue( test ); in TestArenaConcurrency()
540 a.enqueue([&] { in TestMandatoryConcurrency()
683 a.enqueue( tf ); in TestConstantFunctorRequirement()
945 arena.enqueue([&]() { in execute()
997 arena.enqueue([&]() { in TestEnqueue()
1208 ta.enqueue( mpf ); in TestFunctors()
1782 a.enqueue([&] { in test_threads_sleep()
[all …]
H A Dtest_concurrent_monitor.cpp74 arena.enqueue(thread_func);
H A Dtest_task.cpp609 test_arena.enqueue(task_body); in __anon509d20bd1902()
693 test_arena.enqueue(task_body);
697 test_arena2.enqueue(task_body);
703 test_arena.enqueue(check_body);
835 a.enqueue([] { in __anon509d20bd2602()
H A Dtest_global_control.cpp77 a.enqueue(utils::DummyBody() ); in operator ()()
H A Dtest_scheduler_mix.cpp561 tbb::this_task_arena::enqueue([&wctx] { wctx.release(); }); in do_it()
582 entry.first->enqueue([] { global_actor(); }); in do_it()
H A Dtest_tbb_fork.cpp184 arena.enqueue([&]{}); in TestSchedulerMemLeaks()
H A Dtest_collaborative_call_once.cpp354 a1.enqueue([&] { in __anon8532fc100f02()
H A Dtest_queue_node.cpp51 a.enqueue([]{}); in spin_try_get()
H A Dtest_task_group.cpp1001 a.enqueue([i, &tg, &finished, &barrier] { in __anoneb262a490f02()
/oneTBB/doc/main/tbb_userguide/design_patterns/
H A DGUI_Thread.rst65 method ``task_arena::enqueue`` of a ``task_arena`` instance.
67 The semantics of ``enqueue`` cause the task to eventually run on a worker thread
158 using method ``task_arena::enqueue``.
178 a.enqueue(LongTask(hWnd));
182 It is essential to use method ``task_arena::enqueue`` here.
184 the method ``enqueue`` ensures that the function task eventually executes when resources permit,
H A DLocal_Serializer.rst263 - Method ``moveOneItemToReadyPile`` could invoke ``task::enqueue``
264 to enqueue a task that invokes ``item->run()``. Doing so
/oneTBB/python/tbb/
H A Dapi.i125 void enqueue( PyObject *c ) { $self->enqueue(PyCaller(c)); } in enqueue() function
/oneTBB/src/tbb/
H A Darena.cpp506 static void enqueue(d1::task&, d1::task_group_context*, d1::task_arena_base*);
529 void __TBB_EXPORTED_FUNC enqueue(d1::task& t, d1::task_arena_base* ta) { in enqueue() function
530 task_arena_impl::enqueue(t, nullptr, ta); in enqueue()
533 void __TBB_EXPORTED_FUNC enqueue(d1::task& t, d1::task_group_context& ctx, d1::task_arena_base* ta)… in enqueue() function
534 task_arena_impl::enqueue(t, &ctx, ta); in enqueue()
598 void task_arena_impl::enqueue(d1::task& t, d1::task_group_context* c, d1::task_arena_base* ta) { in enqueue() function in tbb::detail::r1::task_arena_impl
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_shutdown_hang.cpp59 test_arena.enqueue(allocatorRandomThrashing); in hangOnExitReproducer()
/oneTBB/src/tbb/def/
H A Dwin64-tbb.def100 ?enqueue@r1@detail@tbb@@YAXAEAVtask@d1@23@PEAVtask_arena_base@523@@Z
101 ?enqueue@r1@detail@tbb@@YAXAEAVtask@d1@23@AEAVtask_group_context@523@PEAVtask_arena_base@523@@Z
H A Dwin32-tbb.def94 ?enqueue@r1@detail@tbb@@YAXAAVtask@d1@23@PAVtask_arena_base@523@@Z
101 ?enqueue@r1@detail@tbb@@YAXAAVtask@d1@23@AAVtask_group_context@523@PAVtask_arena_base@523@@Z
/oneTBB/doc/main/tbb_userguide/Migration_Guide/
H A DTask_API.rst415 tbb::task::enqueue(cb_task);
437 arena.enqueue(c);
449 ``oneapi::tbb::task_arena::enqueue`` is called.
/oneTBB/test/common/
H A Dcommon_arena_constraints.h464 ta.enqueue([&] { in get_arena_affinity()