Home
last modified time | relevance | path

Searched refs:get_platform_max_threads (Results 1 – 22 of 22) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_parallel_invoke.cpp39 …auto concurrency_limit = utils::get_platform_max_threads() < 8 ? utils::get_platform_max_threads()…
102 TestCPUUserTime(utils::get_platform_max_threads());
H A Dtest_partitioner.cpp40 const std::size_t num_threads = 2 * utils::get_platform_max_threads(); in test()
138 utils::SpinBarrier barrier(2 * utils::get_platform_max_threads()); in strict_test()
160 …oneapi::tbb::parallel_for(Range(0, int(100 * utils::get_platform_max_threads()), 1), [&] (const Ra… in test_custom_range()
167 REQUIRE(res.size() == utils::get_platform_max_threads()); in test_custom_range()
H A Dtest_task.cpp125 if (utils::get_platform_max_threads() < 2) return;
169 std::uint32_t threads_num = static_cast<std::uint32_t>(utils::get_platform_max_threads());
199 std::uint32_t task_threads_num = static_cast<std::uint32_t>(utils::get_platform_max_threads());
257 std::uint32_t threads_num = static_cast<std::uint32_t>(utils::get_platform_max_threads());
328 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads());
468 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads());
483 for (std::size_t i = 0; i < utils::get_platform_max_threads(); ++i) {
514 int num_threads_in_test_arena = std::max(2, int(utils::get_platform_max_threads()));
581 std::uint32_t task_number = static_cast<std::uint32_t>(utils::get_platform_max_threads());
633 std::uint32_t thread_number = static_cast<std::uint32_t>(utils::get_platform_max_threads());
[all …]
H A Dtest_collaborative_call_once.cpp147 call_once_threads(utils::get_platform_max_threads(), f);
173 call_once_threads(utils::get_platform_max_threads(), f, 0, -1, -5);
202 call_once_threads(utils::get_platform_max_threads(), func, std::move(mv));
330 std::size_t num_threads = utils::get_platform_max_threads();
348 int num_threads = static_cast<int>(utils::get_platform_max_threads());
H A Dtest_parallel_for.cpp135 RangeType range( 0, utils::get_platform_max_threads(), nullptr, false, ensure_non_emptiness ); in test()
147 static const std::size_t thread_num = utils::get_platform_max_threads(); in test()
281 if (utils::get_platform_max_threads() < 2) { in run_parallel_for_cancellation_test()
431 TestCPUUserTime(utils::get_platform_max_threads());
H A Dtest_tick_count.cpp48 auto num_of_threads = utils::get_platform_max_threads();
H A Dtest_concurrent_monitor.cpp49 std::size_t threads_number = utils::get_platform_max_threads();
H A Dtest_eh_thread.cpp92 if (utils::get_platform_max_threads() < 2) {
H A Dtest_global_control.cpp189 if (utils::get_platform_max_threads() > 1) { in TestExceptions()
H A Dtest_concurrent_vector.cpp172 double t2 = TimeFindPrimes( utils::get_platform_max_threads() ); in TestFindPrimes()
590 std::size_t max_threads = utils::get_platform_max_threads() - 1;
702 REQUIRE(test_vec.size() == utils::get_platform_max_threads());
H A Dtest_task_arena.cpp1513 std::size_t thread_number = utils::get_platform_max_threads(); in ExceptionInExecute()
1611 std::size_t thread_number = utils::get_platform_max_threads(); in StressTestMixFunctionality()
1817 tbb::task_arena arena(int(utils::get_platform_max_threads() * 2));
1825 CHECK(ets.combine(std::plus<int>{}) <= int(utils::get_platform_max_threads()));
1946 std::size_t num_threads = utils::get_platform_max_threads();
H A Dtest_parallel_for_each.cpp208 TestCPUUserTime(utils::get_platform_max_threads());
H A Dtest_arena_priorities.cpp181 const std::size_t max_num_threads = utils::get_platform_max_threads(); in test()
H A Dtest_parallel_sort.cpp422 TestCPUUserTime(utils::get_platform_max_threads());
H A Dtest_scheduler_mix.cpp410 int num_threads = rnd.get() % utils::get_platform_max_threads() + 1; in create()
H A Dtest_flow_graph_priorities.cpp864 std::size_t max_threads = utils::get_platform_max_threads();
/oneTBB/test/conformance/
H A Dconformance_collaborative_call_once.cpp70 std::size_t num_threads = utils::get_platform_max_threads();
90 int num_threads = static_cast<int>(utils::get_platform_max_threads());
H A Dconformance_arena_constraints.cpp86 …SSAGE(oneapi::tbb::info::default_concurrency(numa_indexes[0]) == utils::get_platform_max_threads(),
H A Dconformance_global_control.cpp75 const std::size_t expected_threads = (utils::get_platform_max_threads()==1)? 1 : parallelism; in RunWorkersLimited()
131 const unsigned expected_threads = utils::get_platform_max_threads()==1? in TestAutoInit()
H A Dconformance_enumerable_thread_specific.cpp1079 if (utils::get_platform_max_threads() == 1) { in TestETSIterator()
/oneTBB/test/common/
H A Dutils_concurrency_limit.h51 inline thread_num_type get_platform_max_threads() { in get_platform_max_threads() function
69 … static std::vector<thread_num_type> threads_range = concurrency_range(get_platform_max_threads()); in concurrency_range()
H A Dconcurrent_ordered_common.h136 auto num_threads = utils::get_platform_max_threads(); in test_concurrent_order()