从 boost::timed_wait 通知条件变量只工作一次

Question

我想使用boost::timed_wait 等待事件或在 5 秒后超时。我的问题是我的timed_wait 只接受第一次通知。

更准确地说：

我有某种小型状态机。它只是异步发送一些命令，然后检查它是否成功。这意味着在发送命令后，我的状态机调用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

不，您不必重置条件变量，是的，它可以多次工作。

我相信您看到的是死锁，而不是在第二次等待 m_condition 时失败。当您在 stateMachine() 中调用 timed_wait() 时，您的互斥锁将被解锁，并在 timed_wait() 返回时重新锁定。我猜在等待之后的缺失代码中，您正在调用 callbackEvent()。该方法试图锁定互斥体，但它不能，因为 (a) 它已经在调用者 (stateMachine()) 中锁定并且 (b) boost::mutex 不是可重入的。您可以尝试使用例如recursive_mutex 代替。

Answer 2

好吧，对我来说不是最光明的时刻，我实际上解决了这个问题。上面发布的代码正在编译并按预期工作。实际问题在于事件或超时的处理。由于那里发生的事情与timed_wait 完全无关，我想我不需要在这里解释。所以这个问题可以结束了。

更新：

当然，由于缺少调度方法，上述代码将无法工作。只是为了它，我要在这里提一下：出于测试目的，我只是在我的主函数中创建一个myClass_A 的对象，启动状态机，然后从我的主函数中调用callbackEvent。这确实有效！