Searched defs:AsyncActivity (Results 1 – 3 of 3) sorted by relevance
255 struct AsyncActivity { struct256 typedef async_node_type::gateway_type gateway_type;258 struct work_type { data_type input; gateway_type* gateway; };259 std::atomic<bool> done;260 concurrent_queue<work_type> my_queue;261 std::thread my_service_thread;263 struct ServiceThreadFunc {278 void stop_and_wait() { done = true; my_service_thread.join(); } in stop_and_wait()280 void submit(data_type input, gateway_type* gateway) { in submit()285 AsyncActivity(SpinBarrier& barrier) in AsyncActivity() argument
41 class AsyncActivity { class43 AsyncActivity(int num_) : m_numAsyncThreads(num_) { in AsyncActivity() function in AsyncActivity
673 class AsyncActivity { class682 AsyncActivity(size_t limit) : stop_limit(limit), c(0), thr([this]() { in __anon62ab872d0a02() function in AsyncActivity