Searched defs:AsyncGroup (Results 1 – 1 of 1) sorted by relevance
211 struct AsyncGroup : public RefCounted { struct212 AsyncGroup(AsyncRuntime *runtime, int64_t size) in AsyncGroup() argument215 std::atomic<int> pendingTokens;216 std::atomic<int> numErrors;217 std::atomic<int> rank;220 std::mutex mu;221 std::condition_variable cv;222 std::vector<std::function<void()>> awaiters;