Home
last modified time | relevance | path

Searched refs:max_concurrency (Results 1 – 25 of 28) sorted by relevance

12

/oneTBB/include/oneapi/tbb/
H A Dinfo.h40 , max_concurrency(maximal_concurrency) in numa_id()
49 max_concurrency = maximal_concurrency; in set_max_concurrency()
62 int max_concurrency = -1; member
102 if (c.max_concurrency > 0) { return c.max_concurrency; } in default_concurrency()
H A Dtask_arena.h92 TBB_EXPORT int __TBB_EXPORTED_FUNC max_concurrency(const d1::task_arena_base*);
170 task_arena_base(int max_concurrency, unsigned reserved_for_masters, priority a_priority) in task_arena_base() argument
174 , my_max_concurrency(max_concurrency) in task_arena_base()
187 , my_max_concurrency(constraints_.max_concurrency) in task_arena_base()
333 my_max_concurrency = constraints_.max_concurrency;
430 int max_concurrency() const { in max_concurrency() function
432 return (my_max_concurrency > 1) ? my_max_concurrency : r1::max_concurrency(this); in max_concurrency()
462 inline int max_concurrency() { in max_concurrency() function
463 return r1::max_concurrency(nullptr); in max_concurrency()
490 using detail::d1::max_concurrency;
H A Dpartitioner.h73 return factor * static_cast<std::size_t>(max_concurrency()); in get_initial_auto_partitioner_divisor()
93 unsigned max_threads_in_arena = static_cast<unsigned>(max_concurrency()); in resize()
/oneTBB/doc/main/tbb_userguide/Migration_Guide/
H A DTask_Scheduler_Init.rst20 * `oneapi::tbb::this_task_arena::max_concurrency()
32 * `task_arena(/* max_concurrency */)
36 * `tbb::global_control(tbb::global_control::max_allowed_parallelism, /* max_concurrency */)
59 assert(num_threads == oneapi::tbb::this_task_arena::max_concurrency());
67 assert(num_threads == oneapi::tbb::this_task_arena::max_concurrency());
90 assert(oneapi::tbb::this_task_arena::max_concurrency() == 4);
99 …// No more than two threads is expected; however, tbb::this_task_arena::max_concurrency() can retu…
106 … // No more than two threads is expected; however, tbb::this_task_arena::max_concurrency() is four
109 assert(tbb::this_task_arena::max_concurrency() == 4);
/oneTBB/python/tbb/
H A Dapi.i84 threads = tbb::this_task_arena::max_concurrency();
117 task_arena(int max_concurrency = automatic, unsigned reserved_for_masters = 1);
121 void initialize(int max_concurrency, unsigned reserved_for_masters = 1);
159 inline int this_task_arena_max_concurrency() { return this_task_arena::max_concurrency();} in this_task_arena_max_concurrency()
/oneTBB/test/tbb/
H A Dtest_arena_constraints.cpp114 barrier.initialize(tbb::this_task_arena::max_concurrency()); in __anon2861f8e80202()
116 tbb::blocked_range<size_t>(0, tbb::this_task_arena::max_concurrency()), in __anon2861f8e80202()
166 constraints assignment_c{}; assignment_c.max_concurrency = 1;
184 REQUIRE_MESSAGE(tbb::task_arena{c}.max_concurrency() == custom_concurrency_value, in check_concurrency_level()
H A Dtest_task_arena.cpp452 REQUIRE( my_a.max_concurrency() == tbb::this_task_arena::max_concurrency() ); in operator ()()
474 if (p - reserved < tbb::this_task_arena::max_concurrency()) { in TestArenaConcurrency()
542 CHECK(a.max_concurrency() == 2); in TestMandatoryConcurrency()
623 int default_threads = tbb::this_task_arena::max_concurrency(); in operator ()()
850 …:size_t num_threads = tbb::this_task_arena::max_concurrency() < 3 ? 3 : tbb::this_task_arena::max_… in HeavyMixTest()
1017 int platform_max_thread = tbb::this_task_arena::max_concurrency(); in TestIsolatedExecute()
1059 if (tbb::this_task_arena::max_concurrency() < 3) { in TestDelegatedSpawnWait()
1379 n_threads = tbb::this_task_arena::max_concurrency(); in TestArenaWorkersMigrationWithNumThreads()
1458 if (tbb::this_task_arena::max_concurrency() != 4) { in TestArenaWorkersMigration()
1465 int threads = tbb::this_task_arena::max_concurrency(); in TestDefaultCreatedWorkersAmount()
[all …]
H A Dtest_resumable_tasks.cpp303 if (tbb::this_task_arena::max_concurrency() == 1) { in TestCleanupMaster()
348 … utils::NativeParallelFor(arena.max_concurrency() / 2, [&arena, &tg, &asyncActivity, &iter](int) { in TestNativeThread()
359 CHECK(iter == (arena.max_concurrency() / 2 * 10)); in TestNativeThread()
412 …bb::global_control::max_allowed_parallelism, std::max(tbb::this_task_arena::max_concurrency(), 16)) in TestCaseGuard()
H A Dtest_hw_concurrency.cpp99 REQUIRE(tbb::this_task_arena::max_concurrency() == availableProcs);
H A Dtest_task_group.cpp763 if (tbb::this_task_arena::max_concurrency() < 2) {
831 if (tbb::this_task_arena::max_concurrency() < 2) {
904 if (tbb::this_task_arena::max_concurrency() < 2) {
927 if (tbb::this_task_arena::max_concurrency() < 2) {
990 int num_threads = tbb::this_task_arena::max_concurrency();
H A Dtest_flow_graph.cpp163 CHECK_MESSAGE(midway_arena->max_concurrency() == 2, ""); in check_arena()
164 CHECK_MESSAGE(tbb::this_task_arena::max_concurrency() == 1, ""); in check_arena()
H A Dtest_global_control.cpp115 gSeed = tbb::this_task_arena::max_concurrency(); in TestMultpleWait()
H A Dtest_openmp.cpp137 int tbb_nthreads = tbb::this_task_arena::max_concurrency(); in TestNumThreads()
H A Dtest_tbb_header.cpp269 TestFuncDefinitionPresence( this_task_arena::max_concurrency, (), int ); in DefinitionPresence()
H A Dtest_flow_graph_priorities.cpp79 … unsigned(current_task_index) < node_num - (node_num % tbb::this_task_arena::max_concurrency()); in body_func()
131 const int num_threads = tbb::this_task_arena::max_concurrency(); in test_node()
/oneTBB/test/conformance/
H A Dconformance_task_arena.cpp43 CHECK(oneapi::tbb::this_task_arena::max_concurrency() == 2); in __anon3e0b77410102()
124 REQUIRE(arena.max_concurrency() == copy.max_concurrency());
H A Dconformance_input_node.cpp174 oneapi::tbb::this_task_arena::max_concurrency());
/oneTBB/examples/common/utility/
H A Dget_default_num_threads.hpp24 return oneapi::tbb::this_task_arena::max_concurrency(); in get_default_num_threads()
/oneTBB/src/tbb/
H A Dtcm_adaptor.cpp158 my_permit_request.cpu_constraints->max_concurrency = my_permit_request.max_sw_threads; in request_permit()
181 my_permit_constraints.max_concurrency = constraints.max_concurrency; in init()
H A Dtcm.h99 int32_t max_concurrency; member
H A Darena.cpp505 static int max_concurrency(const d1::task_arena_base*);
525 int __TBB_EXPORTED_FUNC max_concurrency(const d1::task_arena_base* ta) { in max_concurrency() function
526 return task_arena_impl::max_concurrency(ta); in max_concurrency()
819 int task_arena_impl::max_concurrency(const d1::task_arena_base *ta) { in max_concurrency() function in tbb::detail::r1::task_arena_impl
/oneTBB/include/oneapi/tbb/detail/
H A D_flow_graph_node_impl.h66 …function_input_base( graph &g, size_t max_concurrency, node_priority_t a_priority, bool is_no_thro… in function_input_base() argument
67 : my_graph_ref(g), my_max_concurrency(max_concurrency) in function_input_base()
363 graph &g, size_t max_concurrency, Body& body, node_priority_t a_priority ) in function_input() argument
364 : base_type(g, max_concurrency, a_priority, noexcept(tbb::detail::invoke(body, input_type()))) in function_input()
498 multifunction_input(graph &g, size_t max_concurrency,Body& body, node_priority_t a_priority )
499 …: base_type(g, max_concurrency, a_priority, noexcept(tbb::detail::invoke(body, input_type(), my_ou…
/oneTBB/test/common/
H A Dcommon_arena_constraints.h461 utils::SpinBarrier exit_barrier(ta.max_concurrency()); in get_arena_affinity()
463 for (int i = 0; i < ta.max_concurrency() - 1; ++i) { in get_arena_affinity()
H A Dutils_concurrency_limit.h52 static thread_num_type platform_max_threads = tbb::this_task_arena::max_concurrency(); in get_platform_max_threads()
/oneTBB/src/tbb/def/
H A Dwin64-tbb.def93 ?max_concurrency@r1@detail@tbb@@YAHPEBVtask_arena_base@d1@23@@Z

12