Function workerThread_cb

src/gui2/datastore.cc:56–132

static void wtRebuildConfiguration(bool useCustom);

static void workerThread_cb()
{
    hex::log::debug("worker thread start");

    /* Only call this with pendingTasksMutex taken. */
    auto stopWorkerThread = []
    {
        workerThread.detach();
        workerThread = std::move(std::thread());
        pendingTasks.clear();
        hex::log::debug("worker thread shutdown");
        emergencyStop = busy = false;
    };

    for (;;)
    {
        std::function<void()> cb;

        {
            const std::lock_guard<std::mutex> lock(pendingTasksMutex);
            if (pendingTasks.empty())
            {
                stopWorkerThread();
                return;
            }

            cb = pendingTasks.front();
            pendingTasks.pop_front();
        }

        hex::log::debug("running worker function");

        try
        {
            cb();
        }
        catch (const std::exception& e)
        {
            const std::lock_guard<std::mutex> lock(pendingTasksMutex);
            std::string message = e.what();
            hex::TaskManager::doLater(
                [=]
                {
                    hex::ui::ToastError::open(
                        fmt::format("FluxEngine error: {}", message));
                });
            stopWorkerThread();
            return;
        }
        catch (const EmergencyStopException& e)
        {
            const std::lock_guard<std::mutex> lock(pendingTasksMutex);
            hex::log::debug("worker emergency stop");
            hex::TaskManager::doLater(
                [=]
                {
                    hex::ui::ToastError::open("FluxEngine operation cancelled");
                });