Method blockingWaitWithTimeout

valdi/src/valdi/runtime/Utils/AsyncGroup.cpp:84–105

}

bool AsyncGroup::blockingWaitWithTimeout(const std::chrono::steady_clock::duration& maxTime) {
    std::unique_lock<Mutex> guard(_mutex);
    if (_enterCount == 0) {
        return true;
    }

    auto cond = makeShared<ConditionVariable>();

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

        auto status = cond->waitFor(guard, maxTime);

        lockFreeRemoveFunction(functionId);

        if (status == std::cv_status::timeout) {
            return false;
        }
    }

    return true;
}

int AsyncGroup::lockFreeEnqueueFunction(DispatchFunction function) {
    auto id = ++_callbackSequence;