Method blockingWait

valdi/src/valdi/runtime/Utils/AsyncGroup.cpp:67–82

}

void AsyncGroup::blockingWait() {
    std::unique_lock<Mutex> guard(_mutex);
    if (_enterCount == 0) {
        return;
    }

    auto cond = Valdi::makeShared<ConditionVariable>();

    while (_enterCount != 0) {
        auto functionId = lockFreeEnqueueFunction([cond]() { cond->notifyAll(); });

        cond->wait(guard);

        lockFreeRemoveFunction(functionId);
    }
}

bool AsyncGroup::blockingWaitWithTimeout(const std::chrono::steady_clock::duration& maxTime) {
    std::unique_lock<Mutex> guard(_mutex);