Lines Matching refs:input
258 struct work_type { data_type input; gateway_type* gateway; }; member
271 work.gateway->try_put(work.input); in operator ()()
280 void submit(data_type input, gateway_type* gateway) { in submit()
281 work_type work = { input, gateway }; in submit()
305 ParallelForBody(SpinBarrier& barrier, const data_type& input) in ParallelForBody()
306 : my_barrier(barrier), my_input(input) {} in ParallelForBody()
316 data_type operator()(const data_type& input) { in operator ()()
317 …tbb::parallel_for(0, my_tasks_count, ParallelForBody(my_barrier, input), tbb::simple_partitioner()… in operator ()()
318 return input; in operator ()()
327 void operator()(data_type input, decider_node_type::output_ports_type& ports) { in operator ()()
328 if (input < my_limit) in operator ()()
329 std::get<0>(ports).try_put(input + 1); in operator ()()
339 void operator()(data_type input, async_node_type::gateway_type& gateway) noexcept { in operator ()()
340 my_activity->submit(input, &gateway); in operator ()()