代码拉取完成,页面将自动刷新
本项目为 Swoole 协程工作池,它封装了一些实用的 Swoole 协程操作,使用起来十分一把梭。
用于需要大量协程任务的场景,它可以限定你的同时工作协程数量,并且减少协程频繁创建销毁的损耗。
用于同时执行多个协程,并且能够获取到他们所有的返回值。
宇润PHP全家桶群:17916227 ,如有问题会有人解答和修复。
在您的composer.json中加入配置:
{
"require": {
"yurunsoft/swoole-co-pool": "^1.3.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; // 返回任务执行结果,非必须
}
}
);
$pool->run();
$data = 1; // 可以传递任何参数
// 增加任务,并挂起协程等待返回任务执行结果
$result = $pool->addTask($data);
// 增加任务,异步回调
$result = $pool->addTaskAsync($data, function(ITaskParam $param, $data){
// 异步回调
});
// 增加分组任务,并挂起协程等待返回任务执行结果
$result = $pool->addTask($data, '分组名称');
// 增加分组任务,异步回调
$result = $pool->addTaskAsync($data, function(ITaskParam $param, $data){
// 异步回调
}, '分组名称');
$pool->wait(); // 等待协程池停止,不限时,true/false
$pool->wait(60); // 等待协程池停止,限时60秒,如果为-1则不限时,true/false
每个方法都在单独的协程中被执行,然后可以统一获取到结果。
$batch = new CoBatch([
function(){
return 'imi';
},
'a' => function(){
return 'niu';
},
'b' => function(){
return 'bi';
},
]);
$results = $batch->exec();
// $timeout = -1; // 支持超时
// $limit = -1; // 限制同时工作协程数量
// $results = $batch->exec($timeout, $limit);
var_dump($results);
// $results 值为:
// [
// 'imi',
// 'a' => 'niu',
// 'b' => 'bi',
// ]
快捷函数:
use function Yurun\Swoole\Coroutine\batch;
batch([
function(){
return 'imi';
},
'a' => function(){
return 'niu';
},
'b' => function(){
return 'bi';
},
]);
// batch($callables, $timeout, $limit);
use function Yurun\Swoole\Coroutine\goWait;
$result = goWait(function(){
\Swoole\Coroutine::sleep(1);
return 'wait result';
});
echo $result; // wait result
use Yurun\Swoole\CoPool\ChannelContainer;
go(function(){
$channelContainer = new ChannelContainer;
$id = 'abc';
$data = [
'time' => time(),
];
go(function() use($id, $data, $channelContainer){
echo 'Wait 3 seconds...', PHP_EOL;
\Swoole\Coroutine::sleep(3);
$channelContainer->push($id, $data);
});
var_dump($channelContainer->pop($id));
});
详见 example
目录
开源不求盈利,多少都是心意,生活不易,随缘随缘……
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型