Home
last modified time | relevance | path

Searched refs:ta (Results 1 – 8 of 8) sorted by relevance

/oneTBB/src/tbb/
H A Darena.cpp41 : task_scheduler_observer(*ta) in numa_binding_observer()
510 task_arena_impl::initialize(ta); in initialize()
513 task_arena_impl::terminate(ta); in terminate()
522 task_arena_impl::wait(ta); in wait()
565 …static_cast<d1::task_arena*>(&ta), a.my_num_slots, ta.my_numa_id, ta.core_type(), ta.max_threads_p… in initialize()
588 ta.my_max_concurrency = ta.my_num_reserved_slots + a->my_max_num_workers; in attach()
601 arena* a = ta ? in enqueue()
827 __TBB_ASSERT( !ta || ta->my_max_concurrency==1, nullptr); in max_concurrency()
835 if (ta && ta->my_max_concurrency == 1) { in max_concurrency()
840 if (ta) { in max_concurrency()
[all …]
H A Dobserver_proxy.cpp277 d1::task_arena* ta = p->my_observer->my_task_arena; in observe() local
278 arena* a = ta->my_arena.load(std::memory_order_acquire); in observe()
280 ta->initialize(); in observe()
281 a = ta->my_arena.load(std::memory_order_relaxed); in observe()
/oneTBB/examples/graph/som/
H A Dsom_graph.cpp124 oneapi::tbb::flow::graph *construct_graph(oneapi::tbb::task_arena &ta) { in construct_graph() argument
126 ta.execute([&result] { in construct_graph()
136 void build_BMU_graph(SOMap &map1, oneapi::tbb::task_arena &ta) { in build_BMU_graph() argument
146 g[scnt] = construct_graph(ta); in build_BMU_graph()
175 oneapi::tbb::flow::graph *g_local = construct_graph(ta); in build_BMU_graph()
367 void graph_teach(SOMap &map1, teaching_vector_type &in, oneapi::tbb::task_arena &ta) { in graph_teach() argument
368 build_BMU_graph(map1, ta); in graph_teach()
484 oneapi::tbb::task_arena ta(1); in main() local
492 graph_teach(map1, my_teaching, ta); in main()
546 oneapi::tbb::task_arena ta(p); in main() local
[all …]
/oneTBB/include/oneapi/tbb/
H A Dtask_arena.h101 inline void enqueue_impl(task_handle&& th, d1::task_arena_base* ta) { in enqueue_impl() argument
107 r1::enqueue(*task_handle_accessor::release(th), ctx, ta); in enqueue_impl()
231 void enqueue_impl(F&& f, task_arena_base* ta) { in enqueue_impl() argument
233 …ueue(*alloc.new_object<enqueue_task<typename std::decay<F>::type>>(std::forward<F>(f), alloc), ta); in enqueue_impl()
435 friend void submit(task& t, task_arena& ta, task_group_context& ctx, bool as_critical) { in submit() argument
436 __TBB_ASSERT(ta.is_active(), nullptr); in submit()
438 r1::submit(t, ctx, ta.my_arena.load(std::memory_order_relaxed), as_critical ? 1 : 0); in submit()
/oneTBB/test/common/
H A Dcommon_arena_constraints.h455 system_info::affinity_mask get_arena_affinity(tbb::task_arena& ta) { in get_arena_affinity() argument
457 ta.execute([&]{ in get_arena_affinity()
461 utils::SpinBarrier exit_barrier(ta.max_concurrency()); in get_arena_affinity()
463 for (int i = 0; i < ta.max_concurrency() - 1; ++i) { in get_arena_affinity()
464 ta.enqueue([&] { in get_arena_affinity()
/oneTBB/test/tbb/
H A Dtest_arena_constraints.cpp30 tbb::task_arena ta{constraints}; variable
31 test_constraints_affinity_and_concurrency(constraints, get_arena_affinity(ta));
H A Dtest_hw_concurrency.cpp77 tbb::tbb_allocator<std::size_t> ta; variable
H A Dtest_task_arena.cpp1202 tbb::task_arena ta; in TestFunctors() local
1205 ta.execute( NoMoveNoCopyFunctor() ); in TestFunctors()
1207 ta.enqueue( MoveOnlyFunctor() ); in TestFunctors()
1208 ta.enqueue( mpf ); in TestFunctors()
1211 ta.enqueue( std::move(mpf) ); in TestFunctors()
1988 tbb::task_arena ta; in should_fail() local
1990 …CHECK_THROWS_WITH_AS(ta.enqueue(tbb::task_handle{}), "Attempt to schedule empty… in should_fail()