ahmed2007/suyu
1
0
Fork 0
forked from suyu/suyu
Code Pull requests Activity

Common::Event: add WaitUntil

Browse source
This commit is contained in:
wwylele 2016-12-11 23:26:23 +02:00
parent 51dd13b8a0
commit 2a069e76a5
1 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/common/thread.h
View file

@ -4,6 +4,7 @@
#pragma once
#include <chrono>
#include <condition_variable>
#include <cstddef>
#include <mutex>
@ -54,6 +55,15 @@ public:
is_set = false;
}
template <class Clock, class Duration>
bool WaitUntil(const std::chrono::time_point<Clock, Duration>& time) {
std::unique_lock<std::mutex> lk(mutex);
if (!condvar.wait_until(lk, time, [this] { return is_set; }))
return false;
is_set = false;
return true;
}
void Reset() {
std::unique_lock<std::mutex> lk(mutex);
// no other action required, since wait loops on the predicate and any lingering signal will