c++ - boost:线程不执行在接收到信号后发布的处理程序

Question

我正在熟悉 boost 线程和信号。因此，我正在实现这个简单的示例，我只发布了一个示例类的 cpp 文件，该示例类实现了一个线程，该线程能够在 Signal1 被触发时执行一个方法。该信号是在 Package1Signals 单例中定义的(请原谅这些名称，它们是从模型中生成的)

Class1.hpp

#ifndef CLASS1_HEADER
#define CLASS1_HEADER
#include <boost/asio/io_service.hpp>
#include <boost/asio/ip/udp.hpp>
#include <boost/asio/signal_set.hpp>
#include "Package1.hpp"
#include <boost/thread.hpp>


class Class1{
private:
    boost::asio::io_service service;
public:
    boost::thread  thread;
    Class1();
    void classifierBehavior();
    void Reception1(Signal1 signal1);
    void Reception1Behavior();
};


#endif

Class1.cpp

#include "Class1.hpp"
#include <boost/thread.hpp>
#include <boost/date_time.hpp>
#include "Package1.hpp"
#include "Package2.hpp"
#include "Package1.hpp"

Class1::Class1(){
 //boost::thread thread(boost::bind(&Class1::classifierBehavior,boost::ref(*this)));
 //thread.join();
 thread = boost::thread(&Class1::classifierBehavior,this);
};

void Class1::classifierBehavior(){
  Package1Signals::getInstance()->signal1.connect(boost::bind(&Class1::Reception1, 
  this,_1));
  service.run();

};

 void Class1::Reception1(Signal1 signal1){
std::cout<<"Signal received\n";
service.post(boost::bind(&Class1::Reception1Behavior, this));
 }

 void Class1::Reception1Behavior(){
std::cout<<"Behavior executed\n";
 }

Package1.hpp

#ifndef PACKAGE1_HEADER
#define PACKAGE1_HEADER
#include <boost/signal.hpp>

struct Signal1{   };

class Package1Signals{
private:
    Package1Signals();
    static Package1Signals * instance;
public:
    boost::signal<void(Signal1)> signal1;
    static Package1Signals * getInstance();
 };
 #endif

Package1.cpp

 #include "Package1.hpp"
 Package1Signals * Package1Signals::instance = NULL;
 Package1Signals::Package1Signals(){}
 Package1Signals * Package1Signals::getInstance(){
    if(!instance){
            instance = new Package1Signals();
        }
    return instance;
 }

这是执行它的代码

int main() {
    Class1 test;
    Package1Signals::getInstance()->signal1();
    test.thread.join();
    int k =0;
    std::cin>>k;
    return 0;
 }

我可以看到线程在运行，信号被拦截但发布的处理程序未执行。我究竟做错了什么？

Answer 1

I can see the thread runs, the signal is intercepted

你确定吗？我不认为信号是事件发送的。

but the posted handler is not executed. What am I doing wrong?

您的构造函数创建一个新线程，然后等待它完成，因此构造函数在新线程退出之前不会返回。这意味着 main 中的这一行在接收线程退出之前不会执行:

 Package1Signals::getInstance()->signal1();

也许您希望 boost::thread 成为您的类的成员，因此它与您的类具有相同的生命周期，而不是构造函数中的局部变量。

出于风格的考虑，你不需要使用boost::ref(*this)你可以直接传递this，你不需要使用boost:bind 创建线程，读取docs它告诉你用多个参数构建一个线程等同于将这些参数传递给bind并用结果构建线程，即你可以说

thread(&Class1::classifierBehavior, this);

哪个更简单易读!

更新:现在您已经修复了构造函数，因此它不会阻止您在将接收器连接到信号(发生在新线程中)和发布信号之间出现竞争条件，一旦构造函数完成，就会在主线程中发生。如果新线程需要几毫秒才能开始执行，那么为时已晚并错过信号，因为在主线程中，构造函数将完成并且信号已经发出。

在开始新线程之前尝试连接接收器:

Class1::Class1(){
  Package1Signals::getInstance()->signal1.connect(boost::bind(&Class1::Reception1,   this,_1));
 thread = boost::thread(&Class1::classifierBehavior,this);
};

void Class1::classifierBehavior(){
  service.run();
};

这种方式是在信号发射前连接接收器。

我认为即使事件在服务运行之前发布，io_service 仍然会收到事件，但您可能需要检查一下，否则会有另一场比赛那里的条件。