Lines Matching refs:async_activity
312 class async_activity : utils::NoAssign { class
326 ServiceThreadBody( async_activity* activity ) : my_activity( activity ) {} in ServiceThreadBody()
329 async_activity* my_activity;
332 async_activity(int expected_items, bool deferred = false, int sleep_time = 50) in async_activity() function in async_activity
342 async_activity( const async_activity& ) in async_activity() argument
349 ~async_activity() { in ~async_activity()
415 async_activity<input_type, output_type> my_async_activity(async_expected_items); in run()
534 async_activity<input_type, output_type> my_async_activity(async_expected_items, false, 0); in run()
611 typedef async_activity<input_type, output_type> async_activity_type;
722 AsyncActivity<node_t> async_activity(3); in test_follows() local
733 async_activity.submit(input, >w); in test_follows()
744 async_activity.wait_for_all(); in test_follows()
760 AsyncActivity<node_t> async_activity(1); in test_precedes() local
767 async_activity.submit(input, >w); in test_precedes()
775 async_activity.wait_for_all(); in test_precedes()