| 599 | ~ThreadPool() override = default; |
| 600 | |
| 601 | void enqueue(std::function<void()> fn) override { |
| 602 | { |
| 603 | std::unique_lock<std::mutex> lock(mutex_); |
| 604 | jobs_.push_back(std::move(fn)); |
| 605 | } |
| 606 | |
| 607 | cond_.notify_one(); |
| 608 | } |
| 609 | |
| 610 | void shutdown() override { |
| 611 | // Stop all worker threads... |