设为首页收藏本站

LUPA开源社区

 找回密码
 注册
文章 帖子 博客
LUPA开源社区 首页 业界资讯 软件追踪 查看内容

swoole-co-pool v1.0.1,Swoole协程工作池

2019-4-15 14:54| 发布者: joejoe0332| 查看: 129| 评论: 0|原作者: oschina|来自: oschina

摘要: 介绍 Swoole 协程工作池,它可以限定你的同时工作协程数量,并且减少协程频繁创建销毁的损耗。 Gitee:https://gitee.com/yurunsoft/swoole-co-pool Github:https://github.com/Yurunsoft/swoole-co-pool 原理 事先 ...

介绍

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


酷毙

雷人

鲜花

鸡蛋

漂亮
  • 快毕业了,没工作经验,
    找份工作好难啊?
    赶紧去人才芯片公司磨练吧!!

最新评论

关于LUPA|人才芯片工程|人才招聘|LUPA认证|LUPA教育|LUPA开源社区 ( 浙B2-20090187  

返回顶部