0

ブーストスレッドとシグナルに精通しています。したがって、この単純な例を実装しています。Signal1が起動されたときにメソッドを実行できるスレッドを実装するサンプルクラスのcppファイルのみを投稿します。シグナルは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;
 }

スレッドが実行され、シグナルがインターセプトされますが、ポストされたハンドラーは実行されません。私は何が間違っているのですか？

4

2 に答える 2

3

スレッドが実行され、信号が傍受されていることがわかります

本気ですか？信号はイベント送信ではないと思います。

ただし、投稿されたハンドラーは実行されません。私は何が間違っているのですか？

コンストラクターは新しいスレッドを作成し、それが終了するのを待つため、コンストラクターは新しいスレッドが終了するまで戻りません。つまり、この行はmain、レシーバースレッドが終了するまで実行されません。

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

たぶん、をクラスのメンバーにしたいboost::threadので、コンストラクターのローカル変数ではなく、クラスと同じ存続期間があります。

スタイルの考慮事項については、使用する必要はありません。boost::ref(*this)渡すだけで、スレッドの作成thisに使用する必要はありません。複数の引数を使用してを作成することは、それらの引数をに渡して作成することと同等であると説明しているドキュメントをお読みください。結果のスレッド、つまりあなたはただ言うことができますboost:bindthreadbind

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 に答える