Home
last modified time | relevance | path

Searched refs:parallel_puts (Results 1 – 7 of 7) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_priority_queue_node.cpp55 struct parallel_puts : utils::NoAssign { struct
57 parallel_puts( tbb::flow::priority_queue_node<T> &q ) : my_q(q) {} in parallel_puts() function
175 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
185 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
201 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
215 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
H A Dtest_continue_node.cpp46 struct parallel_puts { struct
50 parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {} in parallel_puts() argument
51 parallel_puts& operator=(const parallel_puts&) = delete;
80 utils::NativeParallelFor( p, parallel_puts<tbb::flow::continue_msg>(n) ); in run_continue_nodes()
154 utils::NativeParallelFor( p, parallel_puts<tbb::flow::continue_msg>(exe_node) ); in continue_nodes_with_copy()
H A Dtest_buffer_node.cpp46 struct parallel_puts : utils::NoAssign { struct
50 parallel_puts( tbb::flow::buffer_node<T> &b ) : my_b(b) {} in parallel_puts() argument
207 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
226 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
252 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
271 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
H A Dtest_queue_node.cpp66 struct parallel_puts : utils::NoAssign { struct
70 parallel_puts( tbb::flow::queue_node<T> &q ) : my_q(q) {} in parallel_puts() argument
261 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
281 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
307 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
325 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
H A Dtest_sequencer_node.cpp56 struct parallel_puts : utils::NoAssign { struct
61 …parallel_puts( tbb::flow::sequencer_node<T> &q, int num_threads ) : my_q(q), my_num_threads(num_th… in parallel_puts() argument
199 utils::NativeParallelFor( num_threads, parallel_puts<T>(s, num_threads) ); in test_parallel()
236 utils::NativeParallelFor( num_threads, parallel_puts<T>(s_copy, num_threads) ); in test_parallel()
H A Dtest_function_node.cpp346 struct parallel_puts : private utils::NoAssign { struct
350 parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {} in parallel_puts() argument
389 utils::NativeParallelFor( p, parallel_puts<InputType>(exe_node) ); in unlimited_concurrency()
H A Dtest_multifunction_node.cpp333 struct parallel_puts : private utils::NoAssign { struct
337 parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {} in parallel_puts() argument
376 utils::NativeParallelFor( p, parallel_puts<InputType>(exe_node) ); in unlimited_concurrency()