boost:线程未执行接收信号后发布的处理程序

boost: thread not executing an handler posted after the reception of a signal

本文关键字：程序 处理 信号 线程 执行 boost      更新时间：2023-10-16

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

类1.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

类1.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 receivedn";
service.post(boost::bind(&Class1::Reception1Behavior, this));
 }
 void Class1::Reception1Behavior(){
std::cout<<"Behavior executedn";
 }

包装1.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

套餐1.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;
 }

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

我可以看到线程运行，信号被拦截

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

但发布的处理程序不会执行。我做错了什么？

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

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

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

出于样式考虑，您不需要使用boost::ref(*this)只需传递this，也不需要使用boost:bind来创建线程，请阅读文档，其中告诉您使用多个参数构造thread等效于将这些参数传递给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仍然会获得事件，但您可能需要检查这一点，否则那里有另一个竞争条件。

thread.join();语句基本上等到线程退出。因此，本质上发生的情况是，在线程退出之前，构造函数不会完成，这相当于在构造函数中运行线程代码。

解决方法是创建线程并将其句柄保留在类中。 在要等待线程完成并加入主线程之前，不要调用thread.join();。

如果您的线程被创建为由 service 运行，则需要运行该服务才能使线程开始工作。因此，您必须在构造函数中执行service.run();，而不是在线程运行的函数中执行。

另外，如果我没记错的话，服务只能在创建它的同一线程中运行。

相关文章：