| 777 | } |
| 778 | |
| 779 | THolder<IThreadPool> CreateThreadPool(size_t threadsCount, size_t queueSizeLimit, const TThreadPoolParams& params) { |
| 780 | THolder<IThreadPool> queue; |
| 781 | if (threadsCount > 1) { |
| 782 | queue.Reset(new TThreadPool(params)); |
| 783 | } else { |
| 784 | queue.Reset(new TFakeThreadPool()); |
| 785 | } |
| 786 | queue->Start(threadsCount, queueSizeLimit); |
| 787 | return queue; |
| 788 | } |