| 549 | ~ThreadPool() override = default; |
| 550 | |
| 551 | void enqueue(std::function<void()> fn) override { |
| 552 | { |
| 553 | std::unique_lock<std::mutex> lock(mutex_); |
| 554 | jobs_.push_back(std::move(fn)); |
| 555 | } |
| 556 | |
| 557 | cond_.notify_one(); |
| 558 | } |
| 559 | |
| 560 | void shutdown() override { |
| 561 | // Stop all worker threads... |