百度智能云 云生態狂歡季 熱門云產品1折起>>>??

介紹

Swoole 協程工作池，它可以限定你的同時工作協程數量，并且減少協程頻繁創建銷毀的損耗。

Gitee：https://gitee.com/yurunsoft/swoole-co-pool

Github：https://github.com/Yurunsoft/swoole-co-pool

原理

事先定好協程數量和工作隊列長度，將所有工作協程事先創建好。

使用?Swoole\Coroutine\Channel?實現工作隊列。

在每個工作協程中，Swoole\Coroutine\Channel->pop()。一旦有新的任務?push?進隊列，就會有一個工作協程被喚醒。

安裝

在您的composer.json中加入配置：

{"require": {"yurunsoft/swoole-co-pool": "~1.0"} }

然后執行composer update命令。

使用

use Yurun\Swoole\CoPool\CoPool; use Yurun\Swoole\CoPool\Interfaces\ICoTask; use Yurun\Swoole\CoPool\Interfaces\ITaskParam;$coCount = 10; // 同時工作協程數 $queueLength = 1024; // 隊列長度 $pool = new CoPool($coCount, $queueLength,// 定義任務匿名類，當然你也可以定義成普通類，傳入完整類名new class implements ICoTask{/*** 執行任務** @param ITaskParam $param* @return mixed*/public function run(ITaskParam $param){// 執行任務return true; // 返回任務執行結果，非必須}} );$data = 1; // 可以傳遞任何參數// 增加任務，并掛起協程等待返回任務執行結果 $result = $pool->addTask($data);// 增加任務，異步回調 $result = $pool->addTask($data, function(ITaskParam $param, $data){// 異步回調 });

代碼示例

詳見?test/test.php

總結

以上是生活随笔為你收集整理的swoole-co-pool v1.0.1，Swoole 协程工作池的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。