Searched refs:max_num_threads (Results 1 – 3 of 3) sorted by relevance
| /oneTBB/test/tbb/ |
| H A D | test_arena_priorities.cpp | 165 std::vector<arena_info>& arenas, std::size_t max_num_threads, unsigned overall_tasks_num ) in wait_work_completion() argument
167 if( max_num_threads > 1 ) in wait_work_completion()
181 const std::size_t max_num_threads = utils::get_platform_max_threads(); in test() local
183 tbb::global_control control(tbb::global_control::max_allowed_parallelism, max_num_threads + 1); in test()
184 concurrency_type signed_max_num_threads = static_cast<int>(max_num_threads); in test()
185 if (1 == max_num_threads) { in test()
190 INFO( "max_num_threads = " << max_num_threads ); in test()
273 utils::SpinBarrier barrier{ max_num_threads }; in test()
278 wait_work_completion( arenas, max_num_threads, overall_tasks_num ); in test()
300 if( i < max_num_threads || i >= repeats * max_num_threads ) in test()
[all …]
|
| /oneTBB/python/tbb/ |
| H A D | __init__.py | 169 def __init__(self, max_num_threads=None, benchmark=False): argument
175 if max_num_threads:
176 self.ctl = global_control(global_control.max_allowed_parallelism, int(max_num_threads))
178 if not max_num_threads:
179 max_num_threads = default_num_threads()
181 _concurrency_barrier(int(max_num_threads))
330 with Monkey(max_num_threads=args.max_num_threads, benchmark=args.benchmark):
|
| /oneTBB/test/conformance/ |
| H A D | conformance_flowgraph.h | 658 auto max_num_threads = oneapi::tbb::this_task_arena::max_concurrency(); in test_concurrency() local
661 max_num_threads); in test_concurrency()
663 …std::vector<int> threads_count = {1, oneapi::tbb::flow::serial, max_num_threads, oneapi::tbb::flow… in test_concurrency()
665 if(max_num_threads > 2) { in test_concurrency()
666 threads_count.push_back(max_num_threads / 2); in test_concurrency()
673 expected_threads = max_num_threads; in test_concurrency()
|