boost :: timed_waitからの通知条件変数は一度しか動作しません

Question

boost::timed_waitを使用して、イベントを待つか、5秒後にタイムアウトします。私の問題は、私のtimed_waitが初めて通知を受け入れるということです。

より正確には：

私は少しステートマシンのいくつかの種類があります。 Commandだけを非同期的にディスパッチし、それが正常に実行されたかどうかをチェックするだけでは何も行いません。これは、私の状態マシンがm_Condition.timed_wait(lock,timeout)を呼び出すコマンドをディスパッチした後であることを意味します。 （m_Conditionは、タイプがboost::condition_variableのメンバ変数です）。

この非同期呼び出しが成功した場合は、m_Conditionを通知するコールバック関数を呼び出す必要があります。コマンドが失敗した場合、コールバック関数を呼び出さないので、timed_waitがタイムアウトするはずです。したがって、コールバック関数は、m_Condition.notify_all()を呼び出す以外に何も機能しません。

問題はこれが最初に動作することだけです。これは、最初にnotify_all()が呼び出された後、その条件変数で再び機能しないことを意味します。私は自分のコールバックをチェックして、それはいつもnotify_all()を呼び出しますが、timed_waitはただ時間切れです。

たぶん、いくつかのサンプルコードは、それが少し明確にする：

myClass_A.hpp

class myClass_A 
{ 
public: 
    void runStateMachine();     // Starts the state machine 
    void callbackEvent();     // Gets called when Async Command was successful 
private: 
    void stateMachine();     // Contains the state machine 
    void dispatchAsyncCommand();   // Dispatches an Asynchronous command 
    boost::thread m_Thread;     // Thread for the state machine 
    boost::condition_variable m_Condition; // Condition variable for timed_wait 
    boost::mutex m_Mutex;     // Mutex 
}; 

myClass_A.cpp

void myClass_A::runStateMachine() 
{ 
    m_Thread = boost::thread(boost::bind(&myClass_A,this)); 
} 
void myClass_A::dispatchAsyncCommand() 
{ 
    /* Dispatch some command Async and then return */ 
    /* The dispatched Command will call callbackEvent() when done */ 
} 
void myClass_A::stateMachine() 
{ 
    boost::mutex::scoped_lock lock(m_Mutex); 
    while(true) 
    { 
     dispatchAsynCommand(); 
     if(!m_Condition.timed_wait(lock, boost::posix_time::milliseconds(5000))) 
     { 
      // Timeout 
     } 
     else 
     { 
      // Event 
     } 
    } 
} 
void myClass_A::callbackEvent() 
{ 
    boost::mutex::scoped_lock lock(m_Mutex); 
    m_Condition.notify_all(); 
} 

だから私は今、何ができるのでしょうか？ condition_variableを複数回使用することはできませんか？それとも何とかリセットする必要がありますか？どんな提案も歓迎です！

Answer 1

私にとっては最も明るい時間ではありません。私は実際問題を解決しました。上記の投稿されたコードはコンパイルされ、意図したとおりに動作します。実際の問題は、イベントまたはタイムアウトの処理中に嘘をつきました。ここで起こったことは絶対に無関係なので、ここで説明する必要はありません。だからこの質問は閉じられるでしょう。

UPDATE：もちろん

上記のコードは、発送方法の欠如ので、動作しません。テスト目的のために、私の主な機能にオブジェクトmyClass_Aを作成し、状態マシンを起動してから、私の主な機能からcallbackEventを呼び出してください。これは実際に動作します！

Answer 2

いいえ、条件変数をリセットする必要はありません。はい、複数回動作します。

私は、m_conditionで2回目を待つときに失敗するのではなく、デッドロックであると考えています。 stateMachine（）でtimed_wait（）を呼び出すと、mutexのロックが解除され、timed_wait（）が戻るとロックされます。私はあなたがcallbackEvent（）を呼び出している待機に続く欠落したコードでそれを推測しています。そのメソッドはmutexをロックしようとしますが、（a）呼び出し元（stateMachine（））に既にロックされていて、（b）boost :: mutexがre-entrantではないからではありません。たとえば、代わりにrecursive_mutex。