Lines Matching refs:tasks_executed
889 …ling(tbb::task_group& tg1, tbb::task_group& tg2, int num_tasks, std::atomic<int>& tasks_executed) { in run_deep_stealing() argument
891 tg2.run([&tg1, &tasks_executed] { in run_deep_stealing()
893 ++tasks_executed; in run_deep_stealing()
911 std::atomic<int> tasks_executed{}; variable
912 tg1.run_and_wait([&tg1, &tg2, &tasks_executed] { in __anoneb262a490702()
913 run_deep_stealing(tg1, tg2, 10000, tasks_executed); in __anoneb262a490702()
914 while (tasks_executed < 100) { in __anoneb262a490702()
918 CHECK(tasks_executed < 10000); in __anoneb262a490702()
921 CHECK(tasks_executed == 10000);
935 std::atomic<int> tasks_executed{}; in __anoneb262a490802() local
939 tg1.run_and_wait([&tg1, &tg2, &tasks_executed, &second_thread_executed] { in __anoneb262a490802()
940 run_deep_stealing(tg1, tg2, 10000, tasks_executed); in __anoneb262a490802()
942 second_thread_executed = tasks_executed; in __anoneb262a490802()
944 } while (second_thread_executed < 100 || second_thread_executed != tasks_executed); in __anoneb262a490802()
945 CHECK(tasks_executed < 10000); in __anoneb262a490802()
948 CHECK(tasks_executed == 10000); in __anoneb262a490802()
950 tasks_executed = 0; in __anoneb262a490802()
952 tg1.run_and_wait([&a2, &tg1, &tg2, &tasks_executed, second_thread_executed] { in __anoneb262a490802()
953 run_deep_stealing(tg1, tg2, second_thread_executed - 1, tasks_executed); in __anoneb262a490802()
954 while (tasks_executed < second_thread_executed - 1) { in __anoneb262a490802()
958 tg2.run([&a2, &tg1, &tasks_executed] { in __anoneb262a490802()
959 a2.execute([&tg1, &tasks_executed] { in __anoneb262a490802()
961 ++tasks_executed; in __anoneb262a490802()
966 while (tasks_executed < second_thread_executed) { in __anoneb262a490802()
970 a2.execute([&tg1, &tg2, &tasks_executed] { in __anoneb262a490802()
971 run_deep_stealing(tg1, tg2, 10000, tasks_executed); in __anoneb262a490802()
975 currently_executed = tasks_executed; in __anoneb262a490802()
977 } while (currently_executed != tasks_executed); in __anoneb262a490802()
978 CHECK(tasks_executed < 10000 + second_thread_executed); in __anoneb262a490802()
983 CHECK(tasks_executed == 10000 + second_thread_executed); in __anoneb262a490802()