RedDoesStuff/eden
1
0
Fork 0
forked from eden-emu/eden
Code Pull requests Activity

common/thread_worker: Add wait for requests method

Browse source
This commit is contained in:
ReinUsesLisp 2021-03-22 21:00:48 -03:00
parent 60e29dd3b0
commit 8645319a49
2 changed files with 11 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/common/thread_worker.cpp
View file

@ -29,6 +29,10 @@ ThreadWorker::ThreadWorker(std::size_t num_workers, const std::string& name) {
}
task = std::move(requests.front());
requests.pop();
if (requests.empty()) {
wait_condition.notify_one();
}
}
task();
@ -55,4 +59,9 @@ void ThreadWorker::QueueWork(std::function<void()>&& work) {
condition.notify_one();
}
void ThreadWorker::WaitForRequests() {
std::unique_lock lock{queue_mutex};
wait_condition.wait(lock, [this] { return stop || requests.empty(); });
}
} // namespace Common