diff options
| author | ReinUsesLisp <reinuseslisp@airmail.cc> | 2021-04-01 01:05:45 -0300 |
|---|---|---|
| committer | ReinUsesLisp <reinuseslisp@airmail.cc> | 2021-07-08 19:03:26 -0300 |
| commit | 6310150fccc9ebdc1f8a1bc0dfb6e9a76a475769 (patch) | |
| tree | 2fcfd8f48297b03e3a9eb03cfe7594c7ead4edaa /src/common/thread_worker.h | |
| parent | 3a0e4487ba182aa546568ffc44c62fa2dd7cbdbe (diff) | |
common/thread_worker: Use unique function
Diffstat (limited to 'src/common/thread_worker.h')
| -rw-r--r-- | src/common/thread_worker.h | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/common/thread_worker.h b/src/common/thread_worker.h index 7a6756eb5f..7e2b04a071 100644 --- a/src/common/thread_worker.h +++ b/src/common/thread_worker.h @@ -11,18 +11,20 @@ #include <vector> #include <queue> +#include "common/unique_function.h" + namespace Common { class ThreadWorker final { public: explicit ThreadWorker(std::size_t num_workers, const std::string& name); ~ThreadWorker(); - void QueueWork(std::function<void()>&& work); + void QueueWork(UniqueFunction<void> work); void WaitForRequests(); private: std::vector<std::thread> threads; - std::queue<std::function<void()>> requests; + std::queue<UniqueFunction<void>> requests; std::mutex queue_mutex; std::condition_variable condition; std::condition_variable wait_condition; |
