Lines Matching refs:task_number
328 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads()); variable
330 tbb::detail::d1::wait_context wait(task_number + 1);
336 for (std::size_t i = 0; i < task_number; ++i) {
343 …REQUIRE_MESSAGE(SpawningTask::execute_counter() == task_number + 1, "Some tasks were not executed"…
468 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads()); variable
470 tbb::detail::d1::wait_context wait(task_number + 1);
479 for (std::size_t i = 0; i < task_number; ++i) {
508 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads()); variable
536 for (std::size_t i = 0; i < task_number; ++i) {
540 wait.reserve(task_number / 2);
541 for (std::size_t i = 0; i < task_number / 2; ++i) {
559 test_arena.execute([&wait, &test_tasks, &test_arena, &test_context, &resumed, task_number] { in __anon509d20bd1302()
560 …:this_task_arena::isolate([&wait, &test_tasks, &test_arena, &test_context, &resumed, task_number] { in __anon509d20bd1302()
562 wait.reserve(task_number / 2); in __anon509d20bd1302()
563 tbb::parallel_for(tbb::blocked_range<std::size_t>(task_number / 2, task_number), in __anon509d20bd1302()
581 std::uint32_t task_number = static_cast<std::uint32_t>(utils::get_platform_max_threads()); variable
584 tbb::detail::d1::wait_context wait(task_number);
601 for (std::size_t j = 0; j < task_number; ++j) {
605 …a.execute([&test_tasks, &task_body, &wait, &test_context, &test_arena, iter_counter, task_number] { in __anon509d20bd1902()
608 for (std::size_t j = 0; j < task_number; ++j) { in __anon509d20bd1902()
612 for (std::size_t j = 0; j < task_number / 2; ++j) { in __anon509d20bd1902()
616 for (std::size_t j = task_number / 2; j < task_number; ++j) { in __anon509d20bd1902()
621 wait.reserve(task_number); in __anon509d20bd1902()
623 wait.release(task_number); in __anon509d20bd1902()
627 …REQUIRE_MESSAGE(task_type::execute_counter() == task_number * iter_counter, "Some task was not exe…
666 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads()); variable
669 tbb::detail::d1::wait_context wait(task_number);
687 for (std::size_t j = 0; j < task_number; ++j) {
710 test_arena.execute([&test_tasks, &wait, &test_context, task_number] { in __anon509d20bd1f02()
711 for (std::size_t j = 0; j < task_number; ++j) { in __anon509d20bd1f02()
716 wait.reserve(task_number); in __anon509d20bd1f02()
719 wait.release(task_number);
722 …REQUIRE_MESSAGE(task_type::execute_counter() == task_number * iter_count, "Some task was not execu…