Lines Matching refs:d1

48 class CountingTask : public tbb::detail::d1::task {
50 CountingTask( Body body, tbb::detail::d1::wait_context& wait ) : my_body(body), my_wait(wait) {} in CountingTask()
52 CountingTask( tbb::detail::d1::wait_context& wait ) : my_wait(wait) {} in CountingTask()
54 task* execute( tbb::detail::d1::execution_data& ) override { in execute()
61 task* cancel( tbb::detail::d1::execution_data& ) override { in cancel()
77 tbb::detail::d1::wait_context& my_wait;
96 tbb::detail::d1::wait_context wait(1); in test_cancellation_on_exception()
106 tbb::detail::d1::execute_and_wait(task, test_context, wait, test_context); in test_cancellation_on_exception()
142 tbb::detail::d1::wait_context wait(1);
148 tbb::detail::d1::execute_and_wait(test_task, test_context, wait, test_context);
176 tbb::detail::d1::wait_context wait(threads_num);
177 tbb::detail::d1::task_group_context test_context;
185 tbb::detail::d1::spawn(vector_test_task[j], test_context);
187 tbb::detail::d1::wait(wait, test_context);
219 tbb::detail::d1::wait_context wait(task_threads_num);
220 tbb::detail::d1::task_group_context test_context;
230 tbb::detail::d1::spawn(vector_test_task[j], test_context);
237 tbb::detail::d1::wait(wait, test_context);
264 tbb::detail::d1::wait_context wait(threads_num);
265 tbb::detail::d1::task_group_context test_context;
270 tbb::detail::d1::spawn(vector_test_task[idx], test_context); in __anon509d20bd0802()
287 …tbb::detail::d1::execute_and_wait(vector_test_task[threads_num - 1], test_context, wait, test_cont…
314 tbb::detail::d1::spawn(my_task_pool[idx], my_test_ctx); in operator ()()
330 tbb::detail::d1::wait_context wait(task_number + 1);
341 tbb::detail::d1::execute_and_wait(first_task, test_context, wait, test_context);
348 struct suspended_task : public tbb::detail::d1::task {
350 suspended_task(tbb::task::suspend_point tag, tbb::detail::d1::wait_context& wait) in suspended_task()
354 task* execute(tbb::detail::d1::execution_data&) override { in execute()
371 task* cancel(tbb::detail::d1::execution_data&) override { in cancel()
377 tbb::detail::d1::wait_context& my_wait;
397 tbb::detail::d1::wait_context wait(1); in __anon509d20bd0b02()
404 tbb::detail::d1::spawn(test_task[0], test_context); in __anon509d20bd0b02()
408 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd0b02()
417 struct bypass_task : public tbb::detail::d1::task {
420 bypass_task(tbb::detail::d1::wait_context& wait, task_pool_type& task_pool, in bypass_task()
425 task* execute(tbb::detail::d1::execution_data&) override { in execute()
450 task* cancel(tbb::detail::d1::execution_data&) override { in cancel()
455 tbb::detail::d1::wait_context& my_wait;
470 tbb::detail::d1::wait_context wait(task_number + 1);
486 tbb::detail::d1::spawn(test_task_pool[ticket], test_context);
501 tbb::detail::d1::execute_and_wait(suspend_task, test_context, wait, test_context);
511 tbb::detail::d1::wait_context wait{ 0 };
575 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd1602()
584 tbb::detail::d1::wait_context wait(task_number);
613 tbb::detail::d1::spawn(test_tasks[j], test_context); in __anon509d20bd1902()
620 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd1902()
669 tbb::detail::d1::wait_context wait(task_number);
712 tbb::detail::d1::spawn(test_tasks[j], test_context); in __anon509d20bd1f02()
715 tbb::detail::d1::wait(wait, test_context); in __anon509d20bd1f02()
726 struct resubmitting_task : public tbb::detail::d1::task {
734 tbb::detail::d1::task* execute(tbb::detail::d1::execution_data& ) override { in execute()
741 tbb::detail::d1::task* cancel( tbb::detail::d1::execution_data& ) override { in cancel()
763 tbb::detail::d1::wait_context wait(critical_task_counter);
807 tbb::detail::d1::wait(wait, test_context);