Lines Matching refs:num_threads

131     const int num_threads = tbb::this_task_arena::max_concurrency();  in test_node()  local
132 utils::SpinBarrier barrier( num_threads ); in test_node()
165 for( unsigned i = 0; i < g_priority_task_index; i += num_threads ) { in test_node()
168 for( unsigned j = i; j < i+num_threads; ++j ) { in test_node()
184 if( g_task_info[i].my_task_index > int(priority_nodes_num + num_threads) ) in test_node()
204 void test( int num_threads ) { in test() argument
205 …INFO( "Testing execution of nodes with priority takes precedence (num_threads=" << num_threads << … in test()
206 tbb::task_arena arena(num_threads); in test()
345 void test( unsigned num_threads ) { in test() argument
346 …INFO( "Testing threads react eagerly on asynchronous tasks (num_threads=" << num_threads << ") - "… in test()
347 if( num_threads == std::thread::hardware_concurrency() ) { in test()
353 const unsigned cpu_threads = unsigned(num_threads); in test()
507 void test( int num_threads ) { in test() argument
508 INFO( "Testing limit execution to priority tasks (num_threads=" << num_threads << ") - " ); in test()
510 tbb::task_arena arena( num_threads ); in test()
516 const int nodes_in_lane = 3 * num_threads; in test()
593 for( auto num_threads : threads_range ) { in execute_outer_graph() local
594 inner_arena.initialize( static_cast<int>(num_threads) ); in execute_outer_graph()
605 for( auto num_threads : threads_range ) { in test_in_arena() local
607 << " arenas, num_threads=" << num_threads << ") - " ); in test_in_arena()
608 outer_arena.initialize( static_cast<int>(num_threads) ); in test_in_arena()
757 void test(int num_threads) { in test() argument
758 tbb::task_arena arena( num_threads ); in test()
765 for (int i = 0; i < 2 * num_threads; ++i) in test()
771 for (int i = 0; i < num_threads; ++i) in test()
782 barrier = num_threads; in test()