Home
last modified time | relevance | path

Searched refs:max_threads (Results 1 – 5 of 5) sorted by relevance

/oneTBB/test/common/
H A Dutils_concurrency_limit.h56 inline std::vector<thread_num_type> concurrency_range(thread_num_type max_threads) { in concurrency_range() argument
59 for(thread_num_type thread_num = 1; thread_num <= max_threads; thread_num += step++) in concurrency_range()
61 if(threads_range.back() != max_threads) in concurrency_range()
62 threads_range.push_back(max_threads); in concurrency_range()
126 int limit_number_of_threads( int max_threads ) { in limit_number_of_threads() argument
127 ASSERT(max_threads >= 1,"The limited number of threads should be positive"); in limit_number_of_threads()
129 if (maxProcs < max_threads) { in limit_number_of_threads()
134 …ASSERT(max_threads <= 64, "LimitNumberOfThreads doesn't support max_threads to be more than 64 on … in limit_number_of_threads()
136 for (int i = 1; i < max_threads; ++i) { in limit_number_of_threads()
159 for (int i = st; i < st + max_threads; ++i) { in limit_number_of_threads()
[all …]
/oneTBB/test/tbb/
H A Dtest_flow_graph_priorities.cpp562 OuterBody( int max_threads, task_arena** inner_arena ) in OuterBody()
563 : my_max_threads(max_threads), my_inner_arena(inner_arena) {} in OuterBody()
584 void execute_outer_graph( bool same_arena, task_arena& inner_arena, int max_threads, in execute_outer_graph() argument
592 auto threads_range = utils::concurrency_range(max_threads); in execute_outer_graph()
601 void test_in_arena( int max_threads, task_arena& outer_arena, task_arena& inner_arena, in test_in_arena() argument
604 auto threads_range = utils::concurrency_range(max_threads); in test_in_arena()
616 void test( int max_threads ) { in test() argument
642 test_in_arena( max_threads, outer_arena, outer_arena, outer_graph, *outer_nodes[0] ); in test()
646 test_in_arena( max_threads, outer_arena, inner_arena, outer_graph, *outer_nodes[0] ); in test()
864 std::size_t max_threads = utils::get_platform_max_threads(); variable
[all …]
H A Dtest_enumerable_thread_specific.cpp113 void do_std_threads( int max_threads, flogged_ets a[] ) { in do_std_threads() argument
116 for (int p = 0; p < max_threads; ++p) { in do_std_threads()
120 for (int p = 0; p < max_threads; ++p) { in do_std_threads()
124 for(int p = 0; p < max_threads; ++p) { in do_std_threads()
H A Dtest_task_arena.cpp1148 const int max_threads = std::min( 4, tbb::this_task_arena::max_concurrency() ); in TestMultipleWaits() local
1150 const int max_threads = std::min( 16, tbb::this_task_arena::max_concurrency() ); in TestMultipleWaits()
1154 for ( int threads = 1; threads <= max_threads; threads += utils::max( threads/2, 1 ) ) { in TestMultipleWaits()
1157 const int bunch_size = max_threads + rnd.get()%max_threads; in TestMultipleWaits()
H A Dtest_concurrent_vector.cpp590 std::size_t max_threads = utils::get_platform_max_threads() - 1; variable
592 …for (std::size_t threads = 1; threads < max_threads; threads = std::size_t(double(threads) * 2.7))…