boost mutex、condition、scoped_lock、私はここで間違って使っていますか？

Question

class MyClass 
{ 
public: 
    void PushMessage(MyMessage m) // Thread 1 calls this 
    { 
     boost::mutex::scoped_lock lock(mMutex); 
     mQueue.push_back(m); 
     mCondition.notify_one(); 
    } 

    MyMessage PopMessage() 
    { 
     boost::mutex::scoped_lock lock(mMutex); 
     while(mQueue.empty()) 
      mCondition.wait(lock); 

     MyMessage message = mQueue.front(); 
     mQueue.pop_front(); 
     return message; 
    } 

    void foo() // thread 2 is running this loop, and supposed to get messages 
    { 
     for(;;) 
     { 
      MyMessage message = PopMessage(); 

      do_something(message); 
     } 
    } 
private: 
    std::deque<MyMessage> mQueue; 

    boost::mutex mMutex; 
    boost::condition mCondition; 
}; 

私は、コードを実行すると、PushMessageが呼び出され、そしてfoo()はPopMessage()に待っているが、PopMessageを返すことはありません。

do_somethingはここでは無関係ではないと思います。

私はここで間違っていますか？ 不思議なことに、上記のコードはMacで正常に動作しましたが、Linuxで問題があります。
ブーストバージョンは1.44.0

は、私はあなたが1の状態待機のためである1が別のスレッドでメソッド呼び出しを同期させるためである2つのミューテックスオブジェクトを、必要だと思うあなた

Answer 1

に感謝です。あなたはそれらを混ぜた。

Answer 2

のではなく、ロックオブジェクトのスコープは、それがロックを解除する前に、あなたはすなわち、待機中のスレッドのブロックを解除する前に手動でPushMessage()でミューテックスのロックを解除しようとすることができ期限切れに

void PushMessage(MyMessage m) // Thread 1 calls this 
{ 
    boost::mutex::scoped_lock lock(mMutex); 
    mQueue.push_back(m); 

    lock.unlock(); // <== manually unlock 

    mCondition.notify_one(); 
} 

その方法をさせる際に、スレッド2ブロック解除スレッド1にロックが含まれ、スレッド2があなたのミューテックスのロックを取得しようとしている「クロスオーバー」時間はありません。私はなぜそれが問題を引き起こすのか分かりませんが、少なくともスレッド1にはまだロックが含まれていますが、少なくともスレッド2は lock.lock()を呼び出そうとしません。