Searched refs:thread_number (Results 1 – 3 of 3) sorted by relevance
633 std::uint32_t thread_number = static_cast<std::uint32_t>(utils::get_platform_max_threads()); variable638 utils::SpinBarrier barrier(thread_number);649 for (std::size_t i = 0; i < thread_number - 1; ++i) {655 TestCPUUserTime(thread_number);752 tbb::global_control gc(tbb::global_control::max_allowed_parallelism, thread_number + 1);754 tbb::task_arena test_arena(2 * thread_number, thread_number);759 std::uint32_t critical_task_counter = 1000 * thread_number;787 utils::SpinBarrier barrier(thread_number + 1);789 tbb::parallel_for(std::uint32_t(0), thread_number + 1, [&] (std::uint32_t) { in __anon509d20bd2302()796 for (std::size_t i = 0; i < thread_number - 1; ++i) {[all …]
1513 std::size_t thread_number = utils::get_platform_max_threads(); in ExceptionInExecute() local1514 int arena_concurrency = static_cast<int>(thread_number) / 2; in ExceptionInExecute()1537 utils::NativeParallelFor(thread_number, parallel_func); in ExceptionInExecute()1538 CHECK(canceled_task == thread_number * 1000); in ExceptionInExecute()1611 std::size_t thread_number = utils::get_platform_max_threads(); in StressTestMixFunctionality() local1631 utils::SpinBarrier thread_barrier(thread_number); in StressTestMixFunctionality()1684 curr_arena->observers.emplace(*curr_arena->arena, thread_number, 1); in StressTestMixFunctionality()1735 for (std::size_t i = 0; i < thread_number - 1; ++i) { in StressTestMixFunctionality()1741 for (std::size_t i = 0; i < thread_number - 1; ++i) { in StressTestMixFunctionality()
90 std::atomic<int> thread_number; variable205 thread_id = thread_number++; in operator ()()