Searched refs:pendingTokens (Results 1 – 1 of 1) sorted by relevance
215 : RefCounted(runtime), pendingTokens(size), numErrors(0), rank(0) {} in AsyncGroup()217 std::atomic<int> pendingTokens; member272 assert(group->pendingTokens > 0 && "wrong group size"); in mlirAsyncRuntimeAddTokenToGroup()275 if (group->pendingTokens.fetch_sub(1) == 1) { in mlirAsyncRuntimeAddTokenToGroup()387 if (group->pendingTokens != 0) in mlirAsyncRuntimeAwaitAllInGroup()388 group->cv.wait(lock, [group] { return group->pendingTokens == 0; }); in mlirAsyncRuntimeAwaitAllInGroup()433 if (group->pendingTokens == 0) { in mlirAsyncRuntimeAwaitAllInGroupAndExecute()