| 751 | class ThreadPool final : public TaskQueue { |
| 752 | public: |
| 753 | explicit ThreadPool(size_t n, size_t mqr = 0) |
| 754 | : shutdown_(false), max_queued_requests_(mqr) { |
| 755 | while (n) { |
| 756 | threads_.emplace_back(worker(*this)); |
| 757 | n--; |
| 758 | } |
| 759 | } |
| 760 | |
| 761 | ThreadPool(const ThreadPool &) = delete; |
| 762 | ~ThreadPool() override = default; |