Блог

 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.
версия boost — 1.44.0

Спасибо

Вместо того, чтобы позволить области действия объекта блокировки истечь до его разблокировки, вы могли бы попытаться вручную разблокировать мьютекс в 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 пытается получить блокировку вашего мьютекса. Я не понимаю, почему это создало бы проблемы, но опять же, по крайней мере, у вас не будет потока 2, пытающегося вызвать lock.lock() , пока поток 1 все еще содержит блокировку.

Я думаю, вам нужны 2 объекта мьютекса, один для синхронизации вызова метода в разных потоках, другой для ожидания условия. Вы их перепутали.