Home
last modified time | relevance | path

Searched refs:num_threads (Results 1 – 25 of 30) sorted by relevance

12

/oneTBB/test/tbb/
H A Dtest_partitioner.cpp40 const std::size_t num_threads = 2 * utils::get_platform_max_threads(); in test() local
41 tbb::global_control concurrency(tbb::global_control::max_allowed_parallelism, num_threads); in test()
42 tbb::task_arena big_arena(static_cast<int>(num_threads)); in test()
58 execution_trace trace(num_threads); in test()
65 tbb::blocked_range<std::size_t>(0, per_thread_iters * num_threads), in test()
85 for (std::size_t thread_id = 0; thread_id < num_threads; ++thread_id) { in test()
120 << num_threads * repeats - num_threads << " possible." in test()
124 return float(range_shifts) / float(repeats * num_threads); in test()
H A Dtest_buffer_node.cpp66 touches( int num_threads ) : my_num_threads(num_threads) { in touches()
199 int test_parallel(int num_threads) { in test_parallel() argument
207 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
209 T *next_value = new T[num_threads]; in test_parallel()
212 for (int i = 0; i < num_threads * N; ++i ) { in test_parallel()
217 for (int tid = 0; tid < num_threads; ++tid) { in test_parallel()
226 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
229 touches< T > t( num_threads ); in test_parallel()
240 touches< T > t( num_threads ); in test_parallel()
254 touches< T > t( num_threads ); in test_parallel()
[all …]
H A Dtest_sequencer_node.cpp61 …arallel_puts( tbb::flow::sequencer_node<T> &q, int num_threads ) : my_q(q), my_num_threads(num_thr… in parallel_puts()
79 touches( int num_threads ) : my_num_threads(num_threads) { in touches()
143 …gets( tbb::flow::sequencer_node<T> &q, int num_threads, touches<T> &t ) : my_q(q), my_num_threads(… in parallel_gets()
164 …allel_put_get( tbb::flow::sequencer_node<T> &s1, tbb::flow::sequencer_node<T> &s2, int num_threads, in parallel_put_get()
195 int test_parallel(int num_threads) { in test_parallel() argument
199 utils::NativeParallelFor( num_threads, parallel_puts<T>(s, num_threads) ); in test_parallel()
201 touches<T> t( num_threads ); in test_parallel()
202 utils::NativeParallelFor( num_threads, parallel_gets<T>(s, num_threads, t) ); in test_parallel()
219 touches<T> t( num_threads ); in test_parallel()
222 … utils::NativeParallelFor( num_threads, parallel_put_get<T>(s1, s3, num_threads, counter, t) ); in test_parallel()
[all …]
H A Dtest_queue_node.cpp88 touches( int num_threads ) : my_num_threads(num_threads) { in touches()
252 int test_parallel(int num_threads) { in test_parallel() argument
261 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
263 T *next_value = new T[num_threads]; in test_parallel()
266 for (int i = 0; i < num_threads * N; ++i ) { in test_parallel()
271 for (int tid = 0; tid < num_threads; ++tid) { in test_parallel()
281 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
284 touches< T > t( num_threads ); in test_parallel()
295 touches< T > t2( num_threads ); in test_parallel()
309 touches< T > t3( num_threads ); in test_parallel()
[all …]
H A Dtest_flow_graph_priorities.cpp132 utils::SpinBarrier barrier( num_threads ); in test_node()
204 void test( int num_threads ) { in test() argument
206 tbb::task_arena arena(num_threads); in test()
345 void test( unsigned num_threads ) { in test() argument
507 void test( int num_threads ) { in test() argument
510 tbb::task_arena arena( num_threads ); in test()
593 for( auto num_threads : threads_range ) { in execute_outer_graph() local
605 for( auto num_threads : threads_range ) { in test_in_arena() local
757 void test(int num_threads) { in test() argument
758 tbb::task_arena arena( num_threads ); in test()
[all …]
H A Dtest_collaborative_call_once.cpp330 std::size_t num_threads = utils::get_platform_max_threads(); variable
331 utils::SpinBarrier barrier{num_threads};
335 tbb::parallel_for<std::size_t>(0, num_threads, [&](std::size_t) { in __anon8532fc100c02()
338 tbb::parallel_for<std::size_t>(0, num_threads, [&](std::size_t) { in __anon8532fc100c02()
348 int num_threads = static_cast<int>(utils::get_platform_max_threads()); variable
349 utils::SpinBarrier barrier(num_threads);
350 tbb::task_arena a1(num_threads), a2(num_threads);
353 for (auto i = 0; i < num_threads - 1; ++i) {
370 tbb::parallel_for(0, num_threads, [&](int) { in __anon8532fc101102()
375 tbb::parallel_for(0, num_threads, [&](int) { in __anon8532fc101102()
H A Dtest_priority_queue_node.cpp167 int test_parallel(int num_threads) { in test_parallel() argument
175 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
176 for (int i = num_threads*N -1; i>=0; --i) { in test_parallel()
185 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
187 NativeParallelFor( num_threads, parallel_gets<T>(q) ); in test_parallel()
193 NativeParallelFor( num_threads, parallel_put_get<T>(q) ); in test_parallel()
201 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
203 NativeParallelFor( num_threads, parallel_gets<T>(q3) ); in test_parallel()
215 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
221 for (int i = num_threads*N -1; i>=0; --i) { in test_parallel()
H A Dtest_limiter_node.cpp130 void test_puts_with_decrements( int num_threads, tbb::flow::limiter_node< T >& lim , tbb::flow::gra… in test_puts_with_decrements() argument
139 utils::NativeParallelFor( num_threads, put_dec_body<T>(lim, accept_count) ); in test_puts_with_decrements()
141 CHECK_MESSAGE( c == N*num_threads, "" ); in test_puts_with_decrements()
142 CHECK_MESSAGE( r.my_count == N*num_threads, "" ); in test_puts_with_decrements()
153 int test_parallel(int num_threads) { in test_parallel() argument
164 utils::NativeParallelFor( num_threads, put_body<T>(lim, accept_count) ); in test_parallel()
174 test_puts_with_decrements(num_threads, lim, g); in test_parallel()
176 test_puts_with_decrements(num_threads, lim_copy, g); in test_parallel()
H A Dtest_concurrent_set.cpp93 size_t num_threads = 4; // Can be changed to 2 for debugging in test_cycles_absense() local
95 utils::NativeParallelFor(num_threads, [&](size_t) { in test_cycles_absense()
102 REQUIRE(mset.count(i) == num_threads); in test_cycles_absense()
H A Dtest_multifunction_node.cpp419 void run_multiport_test(int num_threads) { in run_multiport_test() argument
423 tbb::task_arena arena(num_threads); in run_multiport_test()
453 void test_concurrency(int num_threads) { in test_concurrency() argument
454 tbb::task_arena arena(num_threads); in test_concurrency()
457 run_concurrency_levels<int,std::tuple<int> >(num_threads); in test_concurrency()
458 run_concurrency_levels<int,std::tuple<tbb::flow::continue_msg> >(num_threads); in test_concurrency()
459 run_buffered_levels<int, std::tuple<int> >(num_threads); in test_concurrency()
466 run_multiport_test<int, std::tuple<int, int> >(num_threads); in test_concurrency()
467 run_multiport_test<float, std::tuple<int, double> >(num_threads); in test_concurrency()
H A Dtest_concurrent_map.cpp111 size_t num_threads = 4; // Can be changed to 2 for debugging in test_cycles_absense() local
113 utils::NativeParallelFor(num_threads, [&](size_t) { in test_cycles_absense()
120 REQUIRE(mmap.count(i) == num_threads); in test_cycles_absense()
H A Dtest_task_arena.cpp851 tbb::global_control ctl(tbb::global_control::max_allowed_parallelism, num_threads); in HeavyMixTest()
1018 int num_threads = utils::min( platform_max_thread, 3 ); in TestIsolatedExecute() local
1026 tbb::global_control ctl(tbb::global_control::max_allowed_parallelism, num_threads); in TestIsolatedExecute()
1116 void TestMultipleWaits( int num_threads, int num_bunches, int bunch_size ) { in TestMultipleWaits() argument
1117 tbb::task_arena a( num_threads ); in TestMultipleWaits()
1946 std::size_t num_threads = utils::get_platform_max_threads(); variable
1949 tbb::task_arena arena(static_cast<int>(num_threads) * 2);
1951 utils::SpinBarrier barrier(num_threads * 2);
1954 tbb::parallel_for(std::size_t(0), num_threads * 2, in __anon1d1198c32002()
1965 for (std::size_t i = 0; i < num_threads / 4 + 1; ++i) {
[all …]
H A Dtest_function_node.cpp438 void test_concurrency(int num_threads) { in test_concurrency() argument
439 tbb::global_control thread_limit(tbb::global_control::max_allowed_parallelism, num_threads); in test_concurrency()
440 run_concurrency_levels<int,int>(num_threads); in test_concurrency()
441 run_concurrency_levels<int,tbb::flow::continue_msg>(num_threads); in test_concurrency()
442 run_buffered_levels<int, int>(num_threads); in test_concurrency()
H A Dtest_openmp.cpp81 #pragma omp parallel num_threads(p) in OpenMP_TBB_Convolve()
117 #pragma omp parallel for reduction(+:sum) num_threads(p) in operator ()()
H A Dtest_task_group.cpp990 int num_threads = tbb::this_task_arena::max_concurrency(); variable
991 if (num_threads < 3) {
995 tbb::task_arena a(2*num_threads, num_threads);
996 utils::SpinBarrier barrier(num_threads + 2);
1010 utils::NativeParallelFor(num_threads, [&](int idx) { in __anoneb262a491102()
/oneTBB/test/conformance/
H A Dconformance_collaborative_call_once.cpp70 std::size_t num_threads = utils::get_platform_max_threads(); variable
71 utils::SpinBarrier barrier{num_threads};
77 utils::NativeParallelFor(num_threads, [&](std::size_t) { in __anon8e61f74e0302()
90 int num_threads = static_cast<int>(utils::get_platform_max_threads()); variable
91 utils::SpinBarrier barrier(num_threads);
96 for (int i = 0; i < num_threads-1; ++i) {
H A Dconformance_global_control.cpp46 int num_threads; member
50 num_threads(threads), barr1(b1), barr2(b2) {} in StackSizeRun()
56 …REQUIRE(num_threads*MB == oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::t… in operator ()()
/oneTBB/examples/graph/dining_philosophers/
H A Ddining_philosophers.cpp246 int num_threads; in main() local
253 for (num_threads = options.threads.first; num_threads <= options.threads.last; in main()
254 num_threads = options.threads.step(num_threads)) { in main()
256 num_threads); in main()
262 << num_philosophers << " philosophers with " << num_threads << " threads" in main()
319 << num_philosophers << " philosophers with " << num_threads in main()
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_whitebox.cpp852 const int num_threads = 8; in TestCleanAllBuffers() local
902 const int num_threads = 8; in TestCleanThreadBuffers() local
1131 const int num_threads; member in TestCollapsingMallocFree
1134 initBarrier( num_threads ); in TestCollapsingMallocFree()
1157 const int num_threads; member in TestCollapsingBootstrap::CheckNumAllocs
1167 const int num_threads; member in TestCollapsingBootstrap
1170 initBarrier( num_threads ); in TestCollapsingBootstrap()
1195 void LOCCollapsingTester( int num_threads ) { in LOCCollapsingTester() argument
1201 Scenario scen(num_threads); in LOCCollapsingTester()
1211 const int num_threads = 16; in TestLOC() local
[all …]
/oneTBB/examples/task_arena/fractal/
H A Dfractal.hpp116 int num_threads; member in fractal_group
128 int num_threads = utility::get_default_num_threads(),
139 return num_threads; in get_num_threads()
H A Dfractal.cpp195 arenas[0].initialize(num_threads); in run()
196 arenas[1].initialize(num_threads / 2); in run()
237 num_threads(_num_threads) { in fractal_group()
/oneTBB/src/tbb/
H A Dgovernor.h77 static unsigned num_threads = AvailableHwConcurrency(); in default_num_threads() local
78 return num_threads; in default_num_threads()
/oneTBB/python/rml/
H A Dipc_utils.cpp116 int num_threads = (int)strtol( value, nullptr, 10 ); in get_num_threads() local
117 return num_threads; in get_num_threads()
/oneTBB/test/common/
H A Dnode_handling_support.h407 … for (std::size_t num_threads = utils::MinThread; num_threads <= utils::MaxThread; ++num_threads) { in test_concurrent_merge() local
411 for (std::size_t j = 0; j < num_threads; ++j) { in test_concurrent_merge()
415 …utils::NativeParallelFor(num_threads, [&](std::size_t index) { dst_table.merge(src_tables[index]);… in test_concurrent_merge()
/oneTBB/doc/main/tbb_userguide/Migration_Guide/
H A DTask_Scheduler_Init.rst54 int num_threads = oneapi::tbb::info::default_concurrency();
59 assert(num_threads == oneapi::tbb::this_task_arena::max_concurrency());
67 assert(num_threads == oneapi::tbb::this_task_arena::max_concurrency());

12