0

我开始熟悉 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";
 }

包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;
 }

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

4

2 回答 2

3

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

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

但未执行发布的处理程序。我究竟做错了什么？

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

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

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

出于样式考虑，您不需要使用boost::ref(*this)，您可以只传递this，并且您不需要使用boost:bind来创建线程，请阅读文档，它告诉您构造thread带有多个参数的 a 等效于将这些参数传递给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即使在服务运行之前发布了事件，仍然会收到该事件，但您可能需要检查一下，否则那里还有另一个竞争条件。

于 2012-07-10T18:21:25.877 回答
1

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

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

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

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

于 2012-07-10T18:00:25.870 回答