Searched defs:AsyncGroup (Results 1 – 1 of 1) sorted by relevance
213 struct AsyncGroup : public RefCounted { struct214 AsyncGroup(AsyncRuntime *runtime, int64_t size) in AsyncGroup() argument217 std::atomic<int> pendingTokens;218 std::atomic<int> numErrors;219 std::atomic<int> rank;222 std::mutex mu;223 std::condition_variable cv;224 std::vector<std::function<void()>> awaiters;