如何在 std::thread 中正确嵌入 QEventLoop？

Question

有一个对象包含std::thread，我想在对象被销毁时完成。

最少的工作代码：

#include <thread>
#include <future>
#include <QEventLoop>

struct Connector
{
    Connector(std::string addr, std::function<void(std::string)> cb)
    {
        std::promise<void> barrier;
        auto fut = barrier.get_future();

        m_worker = std::thread([addr, cb, &barrier]()
        {
            QEventLoop loop;
            QTimer::singleShot(0, [this, &barrier, &loop]
            {
                m_quit = [&loop] { QTimer::singleShot(0, &loop, &QEventLoop::quit); };
                barrier.set_value();
            });

            MySocket s(addr, cb);

            loop.exec();
        });

        fut.wait();
    }

    ~Connector()
    {
        m_quit();
        m_worker.join();
    }

    std::thread worker;
    std::function<void()> m_quit;
};

它变得非常快：你可以在loop上调用exit()，只有在它进入exec()之后，你不能在线程之外创建loop。

我只有一个带有信号量的解决方案，该信号量由在此循环中排队等待执行的处理程序释放。当信号量被释放时，我可以确定循环已创建并正在运行，因此可以在需要时使用quit() 消息终止它。

我错过了更简单的方法吗？

Answer 1

也许您可以将 QEventLoop 的 unique_ptr 的引用传递给线程，并在该指针上的销毁调用退出时。像这样：

#include <thread>
#include <QEventLoop>

struct Connector
{
    Connector()
    {
        m_worker = std::thread([=]()
        {
            event_loop = std::make_unique<QEventLoop>();
            loop->exec();
        });
    }

    ~Connector()
    {
        event_loop->exit();
        m_worker.join();
    }

    std::unique_ptr<QEventLoop> event_loop;
    std::thread worker;
};

Answer 2

这是我的看法，基于 katrasnikj 的回答和 std::promise docs，以确保在构造函数完成时线程正在运行。

struct Connector
{
    Connector()
    {
        std::promise<void> barrier;
        auto fut = barrier.get_future();
        worker = std::thread([=](std::promise<void>&& barrier)
        {
            event_loop = std::make_unique<QEventLoop>();
            barrier.set_value();
            event_loop->exec();
        }, std::move(barrier));
        fut.wait();
    }

    ~Connector()
    {
        QTimer::singleShot(0, event_loop.get(), &QEventLoop::quit);
        worker.join();
    }

    std::unique_ptr<QEventLoop> event_loop;
    std::thread worker;
};

但您可能想考虑改用QThread，因为它能够运行自己的事件循环。