## Mix WorkerPool >[info] 该工具类参考 Golang 的协程池设计思想 工作池：设定固定的协程数量并行执行任务的工具类，对于 `IO` 并行处理类需求，能达到非常高的并发性能。相对于直接 `xgo` 开启无限制的协程，具有稳定限流的特点，可避免过高请求被对方屏蔽，或者因突发大量任务导致内存溢出。 ## 组件 使用 [composer]([https://www.phpcomposer.com/](https://www.phpcomposer.com/)) 安装： ~~~ composer require mix/worker-pool ~~~ ## 单次投递 适合大量数据的转换（通过接口、数据库）的场景，基本用法： [>> 到 GitHub 查看 DEMO <<](https://github.com/mix-php/mix-skeleton/blob/master/app/Console/Commands/WorkerPoolCommand.php) - `$maxWorkers` 为工作者数量 - `$jobQueue` 为任务投放队列 - `$maxQueue` 为任务投放队列的容量 - `for ($i = 0; $i < 1000; $i++) {` 循环负责投递任务 - `$jobQueue->push($data);` 投递一个任务数据，参数为 `Worker::handle` 执行时传入的参数 - 当任务投递到任务投放队列中，任务会在 `$maxWorkers` 个工作者中的某一个执行 ## 常驻投递 适合消息队列(MQ)消费处理（发送邮件、短信）的场景，基本用法： [>> 到 GitHub 查看 DEMO <<](https://github.com/mix-php/mix-skeleton/blob/master/app/Console/Commands/WorkerPoolDaemonCommand.php) - `$maxWorkers` 为工作者数量 - `$jobQueue` 为任务投放队列，设置越大 stop 等待时间越长 - `$maxQueue` 为任务投放队列的容量 - `while (true) { ` 循环负责投递任务 - `$this->conn->brPop(` 通过阻塞的方式从 MQ 监听数据 - `$jobQueue->push($data);` 投递一个任务数据，任务数据会再 `Worker::do` 方法中执行 - 当任务投递到任务投放队列中，任务会在 `$maxWorkers` 个工作者中的某一个执行 ## 异常处理 `Worker::do` 方法中执行的代码无法避免会有异常抛出，这时需要用户自行 `try/catch` 处理 ~~~php public function do($data) { try { } catch (\Throwable $exception) { // print log } } ~~~