Lines Matching refs:tbb
46 U operator()( oneapi::tbb::flow_control& control ) const { in operator ()()
70 static const oneapi::tbb::filter_mode filter_table[] = { oneapi::tbb::filter_mode::parallel,
71 oneapi::tbb::filter_mode::serial_in_order,
72 oneapi::tbb::filter_mode::serial_out_of_order};
79 oneapi::tbb::filter_mode mode = filter_table[i]; in TestSingleFilter()
81 oneapi::tbb::filter<void, void> one_filter( mode, body ); in TestSingleFilter()
82 oneapi::tbb::parallel_pipeline( n_tokens, one_filter, context... ); in TestSingleFilter()
84 …oneapi::tbb::parallel_pipeline( n_tokens, oneapi::tbb::filter<void, void>(mode, body), context... … in TestSingleFilter()
86 …oneapi::tbb::parallel_pipeline( n_tokens, oneapi::tbb::make_filter<void, void>(mode, body), contex… in TestSingleFilter()
96 oneapi::tbb::task_group_context context; in TestSingleFilterFunctor()
104 TestSingleFilter([]( oneapi::tbb::flow_control& control ) { in TestSingleFilterLambda()
111 oneapi::tbb::task_group_context context; in TestSingleFilterLambda()
112 TestSingleFilter([]( oneapi::tbb::flow_control& control ) { in TestSingleFilterLambda()
121 void RunPipeline(const oneapi::tbb::filter<I, O> &filter) in RunPipeline()
125 auto f_beg = oneapi::tbb::make_filter<void, I>(oneapi::tbb::filter_mode::serial_out_of_order, in RunPipeline()
126 [&flag](oneapi::tbb::flow_control& fc) -> I{ in RunPipeline()
134 auto f_end = oneapi::tbb::make_filter<O, void>(oneapi::tbb::filter_mode::serial_in_order, in RunPipeline()
137 oneapi::tbb::parallel_pipeline(n_tokens, f_beg & filter & f_end); in RunPipeline()
140 void RunPipeline(const oneapi::tbb::filter<void, void> &filter) in RunPipeline()
142 oneapi::tbb::parallel_pipeline(n_tokens, filter); in RunPipeline()
148 oneapi::tbb::parallel_pipeline( n_tokens, in RootSequence()
149 oneapi::tbb::make_filter<void,ValueType>( in RootSequence()
150 oneapi::tbb::filter_mode::serial_in_order, in RootSequence()
151 [&first, &last](oneapi::tbb::flow_control& fc)-> ValueType{ in RootSequence()
162 oneapi::tbb::make_filter<ValueType,ValueType>( in RootSequence()
163 oneapi::tbb::filter_mode::parallel, in RootSequence()
166 oneapi::tbb::make_filter<ValueType,void>( in RootSequence()
167 oneapi::tbb::filter_mode::serial_in_order, in RootSequence()
211 oneapi::tbb::filter_mode mode = filter_table[i];
212 oneapi::tbb::filter<I, O> default_filter;
214 auto made_filter1 = oneapi::tbb::make_filter<I,O>(mode, [](I)->O{return O();}); in __anon5895f2ca0802()
215 …static_assert(std::is_same<oneapi::tbb::filter<I, O>, decltype(made_filter1)>::value, "make_filter…
218 auto made_filter2 = oneapi::tbb::make_filter(mode, [](I)->O{return O();}); in __anon5895f2ca0902()
219 …static_assert(std::is_same<oneapi::tbb::filter<I, O>, decltype(made_filter2)>::value, "make_filter…
222 oneapi::tbb::filter<I, O> one_filter(mode, [](I)->O{return O();}); in __anon5895f2ca0a02()
225 oneapi::tbb::filter<I, O> copy_filter(one_filter);
251 auto filter_chain = oneapi::tbb::filter<void, I>(filter_table[i], input_filter<I>()) &
252 oneapi::tbb::filter<I, O>(filter_table[j], middle_filter<I,O>()) &
253 oneapi::tbb::filter<O, void>(filter_table[k], output_filter<O>());
256 …oneapi::tbb::filter<void, I> filter1 = oneapi::tbb::filter<void, I>(filter_table[i], input_filter<…
257 …oneapi::tbb::filter<I, O> filter2 = oneapi::tbb::filter<I, O>(filter_table[j], middle_filter<I,O>(…
258 …oneapi::tbb::filter<O, void> filter3 = oneapi::tbb::filter<O, void>(filter_table[k], output_filter…
281 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
284 oneapi::tbb::filter<void,short> filter1(oneapi::tbb::filter_mode::serial_out_of_order,
285 [&serial_checker](oneapi::tbb::flow_control&fc)
298 oneapi::tbb::filter<short, short> filter2(oneapi::tbb::filter_mode::serial_in_order,
308 oneapi::tbb::filter<short,int> filter3(oneapi::tbb::filter_mode::parallel,
318 oneapi::tbb::filter<int,void> filter4(oneapi::tbb::filter_mode::serial_in_order,
324 oneapi::tbb::parallel_pipeline(n_tokens, filter1 & filter2 & filter3 & filter4);
336 oneapi::tbb::filter<void,int> filter1(oneapi::tbb::filter_mode::parallel,
337 [&active_tokens](oneapi::tbb::flow_control&fc)
350 oneapi::tbb::filter<int,int> filter2(oneapi::tbb::filter_mode::parallel,
360 oneapi::tbb::filter<int,void> filter3(oneapi::tbb::filter_mode::serial_out_of_order,
369 oneapi::tbb::parallel_pipeline(i, filter1 & filter2 & filter3);
383 oneapi::tbb::filter fc1(oneapi::tbb::filter_mode::serial_in_order, i_filter);
384 static_assert(std::is_same_v<decltype(fc1), oneapi::tbb::filter<void, T>>);
386 oneapi::tbb::filter fc2 (fc1);
387 static_assert(std::is_same_v<decltype(fc2), oneapi::tbb::filter<void, T>>);
390 oneapi::tbb::filter fc3(oneapi::tbb::filter_mode::serial_in_order, m_filter);
391 static_assert(std::is_same_v<decltype(fc3), oneapi::tbb::filter<T, std::size_t>>);
393 …oneapi::tbb::filter frv(oneapi::tbb::filter_mode::serial_in_order, [](int&&) -> double { return 0.… in __anon5895f2ca1202()
394 …oneapi::tbb::filter fclv(oneapi::tbb::filter_mode::serial_in_order, [](const int&) -> double { ret… in __anon5895f2ca1302()
395 …oneapi::tbb::filter fc(oneapi::tbb::filter_mode::serial_in_order, [](const int) -> double { return… in __anon5895f2ca1402()
397 static_assert(std::is_same_v<decltype(frv), oneapi::tbb::filter<int, double>>);
398 static_assert(std::is_same_v<decltype(fclv), oneapi::tbb::filter<int, double>>);
399 static_assert(std::is_same_v<decltype(fc), oneapi::tbb::filter<int, double>>);
414 auto first_body = [&](oneapi::tbb::flow_control& fc) -> middle_filter_type { in test_pipeline_invoke_basic()
421 …auto first_filter = oneapi::tbb::make_filter<void, middle_filter_type>(oneapi::tbb::filter_mode::s… in test_pipeline_invoke_basic()
422 …auto middle_filter = oneapi::tbb::make_filter<middle_filter_type, output_filter_type>(oneapi::tbb:… in test_pipeline_invoke_basic()
423 …auto last_filter = oneapi::tbb::make_filter<output_filter_type, void>(oneapi::tbb::filter_mode::se… in test_pipeline_invoke_basic()
425 oneapi::tbb::parallel_pipeline(16, first_filter & middle_filter & last_filter); in test_pipeline_invoke_basic()