Lines Matching refs:task
48 class CountingTask : public tbb::detail::d1::task {
54 task* execute( tbb::detail::d1::execution_data& ) override { in execute()
61 task* cancel( tbb::detail::d1::execution_data& ) override { in cancel()
101 CountingTask<decltype(throw_body)> task(throw_body, wait); in test_cancellation_on_exception() local
106 tbb::detail::d1::execute_and_wait(task, test_context, wait, test_context); in test_cancellation_on_exception()
117 …REQUIRE_MESSAGE(task.execute_counter() == (reset_ctx ? iter_counter : 1), "Some task was not execu… in test_cancellation_on_exception()
118 …REQUIRE_MESSAGE(task.cancel_counter() == iter_counter, "Some task was not canceled after the excep… in test_cancellation_on_exception()
119 task.reset(); in test_cancellation_on_exception()
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()
367 tbb::task::resume(my_suspend_tag); in execute()
371 task* cancel(tbb::detail::d1::execution_data&) override { in cancel()
376 tbb::task::suspend_point my_suspend_tag;
401 … tbb::task::suspend([&wait, &test_context, &test_task, thread_id] (tbb::task::suspend_point tag) { in __anon509d20bd0b02()
417 struct bypass_task : public tbb::detail::d1::task {
421 std::atomic<int>& resume_flag, tbb::task::suspend_point& suspend_tag) in bypass_task()
425 task* execute(tbb::detail::d1::execution_data&) override { in execute()
430 tbb::task::resume(my_suspend_tag); in execute()
434 task* next = ticket < my_task_pool.size() ? &my_task_pool[ticket] : nullptr; in execute()
442 tbb::task::resume(my_suspend_tag); in execute()
450 task* cancel(tbb::detail::d1::execution_data&) override { in cancel()
458 tbb::task::suspend_point& my_suspend_tag;
475 tbb::task::suspend_point test_suspend_tag;
492 … tbb::task::suspend([&resume_flag, &test_suspend_tag, thread_id] (tbb::task::suspend_point tag) { in __anon509d20bd0e02()
521 tbb::task::suspend_point test_suspend_tag;
528 tbb::task::resume(test_suspend_tag); in __anon509d20bd1002()
547 … tbb::task::suspend([&resume_flag, &test_suspend_tag, thread_id] (tbb::task::suspend_point tag) { in __anon509d20bd1102()
634 tbb::concurrent_vector<tbb::task::suspend_point> suspend_points;
642 tbb::task::suspend([&] (tbb::task::suspend_point sp) { in __anon509d20bd1a02()
658 tbb::task::resume(sp);
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()