我想了解如何使用timed_wait
。我发现只有几个例子(here和here),并且在绝对时间调用它时遇到问题。下面的代码是一个简化的例子,实际上这一切都发生在一个类中,所以我认为手动检查我的谓词会更容易,而不必使用一些绑定并将其传递给timed_wait
。为什么在绝对时间调用boost :: timed_wait块时会永远阻塞?
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/thread.hpp>
#include <iostream>
bool done = false;
boost::mutex mutex;
boost::thread waitingThread;
boost::condition_variable cond;
void wait(boost::posix_time::time_duration dt){
boost::mutex::scoped_lock lock(mutex);
boost::system_time x = boost::posix_time::microsec_clock::local_time() + dt;
bool timedOut = false;
while((done == false) && (x > boost::posix_time::microsec_clock::local_time())) {
timedOut = ! cond.timed_wait(lock,x);
}
if (timedOut){ std::cout << "timeout\n"; }
else { std::cout << "success\n"; }
}
void wait2(boost::posix_time::time_duration dt){
boost::mutex::scoped_lock lock(mutex);
bool timedOut = ! cond.timed_wait(lock,dt);
if (timedOut){ std::cout << "timeout\n"; }
else { std::cout << "success\n"; }
}
void test(){
//boost::thread waiter = boost::thread(wait,boost::posix_time::milliseconds(50));
boost::thread waiter = boost::thread(wait2,boost::posix_time::milliseconds(50));
boost::this_thread::sleep(boost::posix_time::milliseconds(2000));
}
第一个版本永远阻塞,我不明白为什么。另一方面,第二个版本afaik会受到虚假唤醒的影响。正如我之前所说的,在实际的代码,这一切都是一个类里面的地方,所以,需要使用带有谓词的过载,我将不得不做一些像
cond.timed_wait(lock,dt, ?bind?(&Foo::isDone,this));
但后来我不是100%肯定,如果一个虚假唤醒将使timed_wait
回报true
(如果这是我的while (x > local_time())
将是多余的情况。