Lines Matching refs:my_async_activity
415 async_activity<input_type, output_type> my_async_activity(async_expected_items); in run() local
426 if(my_async_activity.should_reserve_each_time()) in run()
428 my_async_activity.submit(input, gateway); in run()
534 async_activity<input_type, output_type> my_async_activity(async_expected_items, false, 0); in run() local
546 if(my_async_activity.should_reserve_each_time()) in run()
548 my_async_activity.submit(input, gateway); in run()
618 : spin_barrier(&barrier), my_async_activity(&activity) {} in body_graph_with_async()
629 my_async_activity->submit( input, gateway ); in operator ()()
641 my_async_activity->activate(); in operator ()()
648 async_activity_type* my_async_activity; member in enqueueing_on_inner_level::body_graph_with_async
657 async_activity_type my_async_activity( UNKNOWN_NUMBER_OF_ITEMS, true ); in run() local
659 tbb::parallel_for( 0, nthreads, body_graph_with_async( spin_barrier, my_async_activity ) ); in run()