Searched refs:activity (Results 1 – 6 of 6) sorted by relevance
266 void operator()(AsyncActivity* activity) { in operator ()()267 while (!activity->done) { in operator ()()269 while (activity->my_queue.try_pop(work)) { in operator ()()342 AsyncSubmissionBody(AsyncActivity* activity) : my_activity(activity) {} in AsyncSubmissionBody()367 AsyncActivity activity(barrier); in test() local374 async_node_type async_node(g, unlimited, AsyncSubmissionBody(&activity)); in test()389 activity.stop_and_wait(); in test()
326 ServiceThreadBody( async_activity* activity ) : my_activity( activity ) {} in ServiceThreadBody() argument617 body_graph_with_async( utils::SpinBarrier& barrier, async_activity_type& activity ) in body_graph_with_async() argument618 : spin_barrier(&barrier), my_async_activity(&activity) {} in body_graph_with_async()
51 …activity managed by the user or another runtime. This node receives messages of generic type, in…
28 …me is longer than the lifetimes of all nodes added to the graph and any activity associated with t…
253 No further activity occurs in the graph, and the ``wait_for_all()`` will
288 …r which you make payment to the third party based on the extent of your activity of conveying the …