BOOST如何在线程中发送信号并在另一个线程中执行相应的槽？

Question

例如，如果你在GUI线程之外的线程中发出信号，信号被排队并在GUI线程中稍后执行，那么有没有办法用boost来做到这一点？

谢谢

Answer 1

对于事件循环，请使用boost :: asio :: io_service。您可以在线程安全的方式中在此对象中发布任务并让另一个线程执行它们：

struct MyClass
{
    boost::io_service service;
    void doSomethingOp() const { ... }

    void doSomething()
    {
        service.post(boost::bind(&MyClass::doSomethingOp, this));
    }

    void loop()
    {
            service.run(); // processes the tasks
    }
};

boost::signal<void()> mySignal;

MyClass myClass;
mySignal.connect(boost::bind(&MyClass::doSomething, boost::ref(myClass)));

// launches a thread and executes myClass.loop() there
boost::thread t(boost::bind(&MyClass::loop(), boost::ref(myClass)));

// calls myClass.doSomething() in this thread, but loop() executes it in the other
mySignal(); 

Answer 2

不是直接的，因为boost不提供事件循环。

要在另一个线程中处理信号，另一个线程需要检查处理程序队列，它应该运行并执行它们（这通常意味着某种事件循环）。 Boost不提供一个，所以你需要从别处获取它或写它。

如果你有一个不提供信号的事件循环（或者用队列实现一些简单的解决方案）你应该能够（ab）使用boost.signals2（而不是boost.signals，因为那个版本不是线程安全的）通过重写operator+=将每个处理程序包装在某个东西中，将其排队以便在另一个线程中执行。您甚至可以为具有返回值的信号实现它（Qt不支持，但受boost支持），但您必须小心避免死锁。

Answer 3

Chila的答案是正确的，但它缺少一件重要的事情：一个boost::thread对象只会调用它传递过一次的函数。由于boost::io_service在发出信号之前没有工作要做，线程将立即完成。为了解决这个问题，有一个boost::asio::io_service::work类。在你调用run()的io_service方法之前，你应该创建一个工作对象并将它传递给io_service：

//as a class variable
std::shared_ptr<boost::asio::io_service::work> worker;

//before you call run() of the io_service yourIOService
worker = std::make_shared<boost::asio::io_service::work>(yourIOService);

//If you want the service to stop
worker.reset();

注意：在撰写本文时（boost 1.67），此方法已被弃用，您应该使用io_context::executor_work_guard（与io_service::work基本相同的功能）。虽然我在使用新方法时无法编译，但工作解决方案仍在使用boost 1.67。

Answer 4

由于某种原因，删除了boost::asio::executor_work_guard<boost::asio::io_context::executor_type>的赋值运算符，但您仍然可以构造它。

这是我的代码版本，它发布了一些可移动的Event对象并在运行io_context::run()的线程上处理它：

class MyClass {
public:
  MyClass () : m_work(boost::asio::make_work_guard(m_service)) {}

  size_t loop() {
    return m_service.run();
  }

  void stop() {
    m_work.reset();
  }

  void doSomething(Event&& e) {
    m_service.post([this, e=std::move(e)]{ doSomethingOp(std::move(e)); });
  }

private:
  void doSomethingOp(const Event& event) {
    ...
  }
//data:
  boost::asio::io_context m_service;
  boost::asio::executor_work_guard<boost::asio::io_context::executor_type> m_work;
};

它需要C ++ 14，并使用VS2017和GCC 6.4进行线程和内存消毒剂测试。