Method recomputeWorker

src/App/Application.cpp:3195–3230

}

void Application::recomputeWorker()
{
    while (!_stopRecomputeThread) {
        std::unique_lock<std::mutex> lock(_recomputeMutex);
        // Wait until either stop is signaled or there is at least one pending request.
        _recomputeRequestAvailable.wait(lock, [this] {
            return _stopRecomputeThread || !_recomputeRequests.empty();
        });
        if (_stopRecomputeThread) {
            break;
        }

        // Process all pending recompute requests.
        while (!_recomputeRequests.empty()) {
            RecomputeRequest request = takeNextRecomputeRequest(_recomputeRequests);
            if (!request.documentName.empty()) {
                _recomputeDocumentsInProgress.insert(request.documentName);
            }

            // Unlock while processing to allow other threads to add new requests.
            lock.unlock();

            RecomputeResult result = processRecomputeRequest(request);

            if (request.callback) {
                request.callback(request, result);
            }

            lock.lock();
            if (!request.documentName.empty()) {
                _recomputeDocumentsInProgress.erase(request.documentName);
                _recomputeStateChanged.notify_all();
            }
        }
    }
}

void Application::logStatus()
{