|
|
|
@ -75,13 +75,15 @@ public:
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Wait till the queue is dequeued.
|
|
|
|
|
* Wait till the queue is dequeued, or a condition is met.
|
|
|
|
|
* @param condition Condition functor.
|
|
|
|
|
*/
|
|
|
|
|
void WaitTillEmpty()
|
|
|
|
|
template <typename T>
|
|
|
|
|
void WaitTillEmptyOrCondition(T condition)
|
|
|
|
|
{
|
|
|
|
|
std::unique_lock<std::mutex> lock(this->mutex);
|
|
|
|
|
|
|
|
|
|
while (!queue.empty()) {
|
|
|
|
|
while (!(queue.empty() || condition())) {
|
|
|
|
|
this->queue_cv.wait(lock);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
@ -95,6 +97,20 @@ public:
|
|
|
|
|
return this->queue.empty();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Clear everything in the queue.
|
|
|
|
|
*
|
|
|
|
|
* Should be called from the Game Thread.
|
|
|
|
|
*/
|
|
|
|
|
void ClearQueue()
|
|
|
|
|
{
|
|
|
|
|
std::lock_guard<std::mutex> lock(this->mutex);
|
|
|
|
|
|
|
|
|
|
this->queue.clear();
|
|
|
|
|
this->queue_cv.notify_all();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
HTTPThreadSafeCallback(HTTPCallback *callback) : callback(callback) {}
|
|
|
|
|
|
|
|
|
|
~HTTPThreadSafeCallback()
|
|
|
|
|