Searched refs:my_async_activity (Results 1 – 1 of 1) sorted by relevance
415 async_activity<input_type, output_type> my_async_activity(async_expected_items); in run() local426 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() local546 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[all …]