Home
last modified time | relevance | path

Searched refs:task_pool (Results 1 – 5 of 5) sorted by relevance

/oneTBB/src/tbb/
H A Darena_slot.h56 std::atomic<d1::task**> task_pool; in alignas() local
169 return task_pool.load(std::memory_order_relaxed) != EmptyTaskPool; in is_task_pool_published()
173 return task_pool.load(std::memory_order_relaxed) == EmptyTaskPool || in is_empty()
279 task_pool.store(task_pool_ptr, std::memory_order_release ); in publish_task_pool()
296 d1::task** tp = task_pool.load(std::memory_order_relaxed); in acquire_task_pool()
317 if ( !(task_pool.load(std::memory_order_relaxed) != EmptyTaskPool) ) in release_task_pool()
320 task_pool.store( task_pool_ptr, std::memory_order_release ); in release_task_pool()
328 victim_task_pool = task_pool.load(std::memory_order_relaxed); in lock_task_pool()
356 task_pool.store(victim_task_pool, std::memory_order_release); in unlock_task_pool()
361 d1::task** tp = task_pool.load(std::memory_order_relaxed); in is_local_task_pool_quiescent()
[all …]
H A Dwaiters.h87 bool is_task_pool_empty = slot.task_pool.load(std::memory_order_relaxed) == EmptyTaskPool; in is_worker_should_leave()
H A Darena.h453 d1::task **pool = victim->task_pool.load(std::memory_order_relaxed); in steal_task()
/oneTBB/include/oneapi/tbb/
H A Dparallel_for_each.h272 for (auto* it = task_pool.begin(); it != task_pool.end(); ++it) {
286 spawn(*(task_pool.begin() + counter), my_execution_context);
289 execute_and_wait(*task_pool.begin(), my_execution_context,
304 (task_pool.begin() + counter)->~iteration_task();
312 aligned_space<iteration_task, max_block_size> task_pool;
335 auto* task_it = task_pool.begin();
351 spawn(*(task_pool.begin() + counter), my_execution_context);
354 execute_and_wait(*task_pool.begin(), my_execution_context,
369 (task_pool.begin() + counter)->~iteration_task();
373 aligned_space<iteration_task, max_block_size> task_pool;
/oneTBB/test/tbb/
H A Dtest_task.cpp305 SpawningTaskBody( task_pool_type& task_pool, tbb::task_group_context& test_ctx ) in SpawningTaskBody() argument
306 : my_task_pool(task_pool), my_test_ctx(test_ctx) {} in SpawningTaskBody()
333 SpawningTaskBody::task_pool_type task_pool; variable
335 SpawningTaskBody task_body{task_pool, test_context};
337 task_pool.emplace_back(task_body, wait);
420 bypass_task(tbb::detail::d1::wait_context& wait, task_pool_type& task_pool, in bypass_task()
422 … : my_wait(wait), my_task_pool(task_pool), my_resume_flag(resume_flag), my_suspend_tag(suspend_tag) in bypass_task()