Lines Matching refs:wait
50 CountingTask( Body body, tbb::detail::d1::wait_context& wait ) : my_body(body), my_wait(wait) {} in CountingTask() argument
52 CountingTask( tbb::detail::d1::wait_context& wait ) : my_wait(wait) {} in CountingTask() argument
96 tbb::detail::d1::wait_context wait(1); in test_cancellation_on_exception() local
101 CountingTask<decltype(throw_body)> task(throw_body, wait); in test_cancellation_on_exception()
106 tbb::detail::d1::execute_and_wait(task, test_context, wait, test_context); in test_cancellation_on_exception()
113 wait.reserve(1); in test_cancellation_on_exception()
115 wait.release(1); in test_cancellation_on_exception()
131 barrier.wait(); in __anon509d20bd0202()
135 barrier.wait();
137 test_gr.wait();
142 tbb::detail::d1::wait_context wait(1); variable
144 CountingTask<> test_task(wait);
148 tbb::detail::d1::execute_and_wait(test_task, test_context, wait, test_context);
149 wait.reserve(1);
152 wait.release(1);
173 barrier.wait(); in __anon509d20bd0302()
176 tbb::detail::d1::wait_context wait(threads_num);
180 …::cache_aligned_allocator<task_type>> vector_test_task(threads_num, task_type(barrier_wait, wait));
187 tbb::detail::d1::wait(wait, test_context);
188 wait.reserve(threads_num);
190 wait.release(threads_num);
203 barrier.wait(); in __anon509d20bd0402()
219 tbb::detail::d1::wait_context wait(task_threads_num);
222 …he_aligned_allocator<task_type>> vector_test_task(task_threads_num, task_type(barrier_wait, wait));
237 tbb::detail::d1::wait(wait, test_context);
245 wait.reserve(task_threads_num);
247 wait.release(task_threads_num);
261 barrier.wait(); in __anon509d20bd0702()
264 tbb::detail::d1::wait_context wait(threads_num);
267 …::cache_aligned_allocator<task_type>> vector_test_task(threads_num, task_type(barrier_wait, wait));
287 …tbb::detail::d1::execute_and_wait(vector_test_task[threads_num - 1], test_context, wait, test_cont…
288 wait.reserve(threads_num);
290 wait.release(threads_num);
330 tbb::detail::d1::wait_context wait(task_number + 1); variable
337 task_pool.emplace_back(task_body, wait);
340 SpawningTask first_task(task_body, wait);
341 tbb::detail::d1::execute_and_wait(first_task, test_context, wait, test_context);
350 suspended_task(tbb::task::suspend_point tag, tbb::detail::d1::wait_context& wait) in suspended_task()
351 : my_suspend_tag(tag), my_wait(wait) in suspended_task()
397 tbb::detail::d1::wait_context wait(1); in __anon509d20bd0b02() local
399 tbb::this_task_arena::isolate([&wait, &test_context, &test_task] { in __anon509d20bd0b02()
401 … tbb::task::suspend([&wait, &test_context, &test_task, thread_id] (tbb::task::suspend_point tag) { in __anon509d20bd0b02()
403 test_task.emplace_back(tag, wait); in __anon509d20bd0b02()
408 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd0b02()
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()
470 tbb::detail::d1::wait_context wait(task_number + 1); variable
480 test_task_pool.emplace_back(wait, test_task_pool, resume_flag, test_suspend_tag);
499 task_type suspend_task(suspend_func, wait);
501 tbb::detail::d1::execute_and_wait(suspend_task, test_context, wait, test_context);
511 tbb::detail::d1::wait_context wait{ 0 }; variable
537 test_tasks.emplace_back(task_body, wait);
540 wait.reserve(task_number / 2);
554 suspend_task_type suspend_task(suspend_func, wait);
556 wait.reserve(1);
559 test_arena.execute([&wait, &test_tasks, &test_arena, &test_context, &resumed, task_number] { in __anon509d20bd1302()
560 …tbb::this_task_arena::isolate([&wait, &test_tasks, &test_arena, &test_context, &resumed, task_numb… in __anon509d20bd1302()
562 wait.reserve(task_number / 2); in __anon509d20bd1302()
574 test_arena.execute([&wait, &test_context] { in __anon509d20bd1602()
575 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd1602()
584 tbb::detail::d1::wait_context wait(task_number);
602 test_tasks.emplace_back(task_body, wait);
605 …test_arena.execute([&test_tasks, &task_body, &wait, &test_context, &test_arena, iter_counter, task… in __anon509d20bd1902()
620 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd1902()
621 wait.reserve(task_number); in __anon509d20bd1902()
623 wait.release(task_number); in __anon509d20bd1902()
640 barrier.wait(); in __anon509d20bd1a02()
645 barrier.wait(); in __anon509d20bd1a02()
653 barrier.wait();
654 barrier.wait();
659 test_gr.wait();
669 tbb::detail::d1::wait_context wait(task_number);
688 test_tasks.emplace_back(task_body, wait);
710 test_arena.execute([&test_tasks, &wait, &test_context, task_number] { in __anon509d20bd1f02()
715 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd1f02()
716 wait.reserve(task_number); in __anon509d20bd1f02()
719 wait.release(task_number);
763 tbb::detail::d1::wait_context wait(critical_task_counter);
770 suspend_task_type critical_task(critical_work, wait);
790 barrier.wait(); in __anon509d20bd2302()
807 tbb::detail::d1::wait(wait, test_context);