Lines Matching refs:threads_num
169 std::uint32_t threads_num = static_cast<std::uint32_t>(utils::get_platform_max_threads()); variable
170 utils::SpinBarrier barrier(threads_num);
176 tbb::detail::d1::wait_context wait(threads_num);
180 …std::vector<task_type, tbb::cache_aligned_allocator<task_type>> vector_test_task(threads_num, task…
184 for (std::size_t j = 0; j < threads_num; ++j) {
188 wait.reserve(threads_num);
190 wait.release(threads_num);
192 …REQUIRE_MESSAGE(task_type::execute_counter() == iter_counter * threads_num, "Some task was not exe…
257 std::uint32_t threads_num = static_cast<std::uint32_t>(utils::get_platform_max_threads()); variable
258 utils::SpinBarrier barrier(threads_num);
264 tbb::detail::d1::wait_context wait(threads_num);
267 …std::vector<task_type, tbb::cache_aligned_allocator<task_type>> vector_test_task(threads_num, task…
277 for (std::size_t k = 0; k < threads_num - 1; ++k) {
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);
292 …REQUIRE_MESSAGE(task_type::execute_counter() == iter_count * threads_num, "Some task was not execu…