| 667 | ~ThreadPool() override = default; |
| 668 | |
| 669 | void enqueue(std::function<void()> fn) override { |
| 670 | { |
| 671 | L_unique_lock<L_mutex> lock(mutex_); |
| 672 | jobs_.push_back(std::move(fn)); |
| 673 | } |
| 674 | |
| 675 | cond_.notify_one(); |
| 676 | } |
| 677 | |
| 678 | void shutdown() override { |
| 679 | // Stop all worker threads... |