百度智能云 云生態(tài)狂歡季 熱門云產(chǎn)品1折起>>>??

介紹

Swoole 協(xié)程工作池，它可以限定你的同時(shí)工作協(xié)程數(shù)量，并且減少協(xié)程頻繁創(chuàng)建銷毀的損耗。

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

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

原理

事先定好協(xié)程數(shù)量和工作隊(duì)列長度，將所有工作協(xié)程事先創(chuàng)建好。

使用?Swoole\Coroutine\Channel?實(shí)現(xiàn)工作隊(duì)列。

在每個(gè)工作協(xié)程中，Swoole\Coroutine\Channel->pop()。一旦有新的任務(wù)?push?進(jìn)隊(duì)列，就會有一個(gè)工作協(xié)程被喚醒。

安裝

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

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

然后執(zhí)行composer update命令。

使用

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

代碼示例

詳見?test/test.php

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。