协程池
最后更新于:2022-04-02 07:05:16
## 协程池
>[info] 该工具类参考 Golang 的协程池设计思想
协程池:设定固定的协程数量并行执行任务的工具类,对于 `IO` 并行处理类需求,能达到非常高的并发性能。
[>> 到 GitHub 查看 DEMO <<](https://github.com/mix-php/mix-skeleton/tree/v2.1/app/Console/Commands/CoroutinePoolCommand.php)
### 讲解
- `$maxWorkers` 为工作者数量
- `$jobQueue` 为任务投放队列
- `$maxQueue` 为任务投放队列的容量
- for 循环负责投递任务
- `$jobQueue->push($data);` 投递一个任务数据,参数为 `Worker::handle` 执行时传入的参数。
- 当任务投递到任务投放队列中,任务会在 `$maxWorkers` 个工作者中的某一个执行。
## 使用场景
协程池是一个具备非常高的实用价值的工具类,使用场景:
- 消息队列(MQ)消费处理(发送邮件、短信)
- 大量数据的转换(通过接口、数据库)
';