| 671 | class ThreadPool final : public TaskQueue { |
| 672 | public: |
| 673 | explicit ThreadPool(size_t n, size_t mqr = 0) |
| 674 | : shutdown_(false), max_queued_requests_(mqr) { |
| 675 | while (n) { |
| 676 | threads_.emplace_back(worker(*this)); |
| 677 | n--; |
| 678 | } |
| 679 | } |
| 680 | |
| 681 | ThreadPool(const ThreadPool &) = delete; |
| 682 | ~ThreadPool() override = default; |