diff options
Diffstat (limited to 'src/common/thread_worker.h')
-rw-r--r-- | src/common/thread_worker.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/common/thread_worker.h b/src/common/thread_worker.h index f1859971f..7a6756eb5 100644 --- a/src/common/thread_worker.h +++ b/src/common/thread_worker.h @@ -18,12 +18,14 @@ public: explicit ThreadWorker(std::size_t num_workers, const std::string& name); ~ThreadWorker(); void QueueWork(std::function<void()>&& work); + void WaitForRequests(); private: std::vector<std::thread> threads; std::queue<std::function<void()>> requests; std::mutex queue_mutex; std::condition_variable condition; + std::condition_variable wait_condition; std::atomic_bool stop{}; }; |