基于swoole的swoolefy实现类似go的waitGroup多并发协程调度

ZweiZhao 发布于2019-07-01 12:44 / 1215人阅读

摘要：基于实用，抽象事件处理类，实现与底层的回调的解耦，支持协程调度，同步异步调用，全局事件注册，心跳检查，异步任务，多进程池等，内置等常用组件等。

swoolefy是一个基于swoole实现的轻量级高性能的常驻内存型的API和Web应用服务框架，高度封装了http，websocket，udp服务器，以及基于tcp实现可扩展的rpc服务，同时支持composer包方式安装部署项目。基于实用，swoolefy抽象Event事件处理类，实现与底层的回调的解耦，支持协程调度，同步|异步调用，全局事件注册，心跳检查，异步任务，多进程(池)等，内置view、log、session、mysql、redis、mongodb等常用组件等。

目前swoolefy4.2+版本完全支持swoole4.2.13+的协程，推荐使用swoole4.3+

GitHub：https://github.com/bingcool/s...

下面主要讲解一下如何实现了类似go的waitGroup的功能
1、定义GoWaitGroup的类：


+----------------------------------------------------------------------
 */

namespace SwoolefyCore;

use SwooleCoroutineChannel;

class GoWaitGroup {
    /**
     * @var int
     */
    private $count = 0;

    /**
     * @var Channel
     */
    private $chan;

    /**
     * @var array
     */
    private $result = [];

    /**
     * WaitGroup constructor
     */
    public function __construct() {
        $this->chan = new Channel;
    }

    /**
     * add
     */
    public function go(Closure $go_func = null) {
        $this->count++;
        if($go_func instanceof Closure) {
            go($go_func);
        }
    }

    /**
     * start
     */
    public function start() {
        $this->count++;
        return $this->count;
    }

    /**
     * done
     */
    public function done(string $key, $data = null) {
        if(!empty($data)) {
            $this->result[$key] = $data;
        }
        $this->chan->push(1);
    }

    /**
     * wait
     */
    public function wait() {
        while($this->count--) {
            $this->chan->pop();
        }
        $result = $this->result;
        $this->result = [];
        $this->count = 0;
        return $result;
    }

}

2、在swoolefy中调用

class GroupController extends BController {
    public function waitgroup() {
        // 创建一个waitGroup实例
        $wg = new SwoolefyCoreGoWaitGroup();
         
         // 第一种方式，直接$wg->go()函数中执行go的协程函数
        $wg->go(function() use ($wg) {
            // 挂起协程
            $fp = stream_socket_client("tcp://www.baidu.com:80", $errno, $errstr, 30);
            // 协程返回的数据
            $wg->done("mysql", "mysql");
        });

        $wg->go(function() use ($wg) {
            sleep(1);
            $wg->done("tengxun", "weixin and qq");
        });

        //挂起当前协程，等待所有任务完成后恢复
        //$result = $wg->wait();
        //这里 $result 包含了 1 个任务执行结果
        //var_dump($result);
        
        //第二种方式，添加$wg->start()，启动协程，然后使用swoole的原生go执行协程函数
        $wg->start();
        go(function () use ($wg) {
            // 挂起协程
            sleep(1);
            $wg->done("taobao", "ali baba");
        });
        
         //第二种方式，添加$wg->start()，启动协程，然后使用swoole的原生go执行协程函数
        $wg->start();
        go(function () use ($wg) {
            // 挂起协程
            sleep(1);
            $wg->done("baidu", "baidu");
        });
        // 以上三个协程将会并发调用，wait()函数实现等待三个协程数据返回
        //挂起当前协程，让出cpu控制权，cpu可以做其他的事情，直到待所有任务完成后恢复
        $result = $wg->wait();
        //这里 $result 包含了 2 个任务执行结果
        var_dump($result);
    }
}

至此一个最简单的并发调用就完成了，你可以愉快使用gowaitGroup的协程调用了

云服务器私有云基于webrtc的电话回声消除的研究与实现基于webrtc的视频会议系统的设计与实现多进程实现并发服务器多线程实现并发服务器

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/31360.html

Easyswoole 源码学习和个人解析目录

摘要：易用稳定，本次想通过对的学习和个人解析，吸收框架的思想和设计知识，加强自己对的认知和理解。当然，笔者能力水平有限，后续的文章如有错误，还请指出和谅解。目录如下后续添加文章都会记录在此服务启动过程以及主体设计流程源码解析前言 swoole是什么？官网的原话介绍是这样的： Swoole 使用纯 C 语言编写，提供了 PHP 语言的异步多线程服务器，异步 TCP/UDP 网络客户端，异步 ...

CoXie 2019-07-01 10:05 评论0 收藏0
PHP 协程：Go + Chan + Defer

摘要：为语言提供了强大的协程编程模式。提供的协程语法借鉴自，在此向开发组致敬协程可以与很好地互补。并发执行使用创建协程，可以让和两个函数变成并发执行。协程需要拿到请求的结果。 Swoole4为PHP语言提供了强大的CSP协程编程模式。底层提供了3个关键词，可以方便地实现各类功能。 Swoole4提供的PHP协程语法借鉴自Golang，在此向GO开发组致敬 PHP+Swoole协程可以与...

nidaye 2019-07-01 11:01 评论0 收藏0
swoolefy-基于swoole扩展实现的高性能的常驻内存型API和Web应用服务框架

摘要：是一个基于扩展实现的轻量级高性能的常驻内存型的和应用服务框架高度封装了，，服务器，以及基于实现可扩展的服务，同时支持包方式安装部署项目。基于实用，抽象事件处理类，实现与底层的回调的解耦，支持同步异步调用，内置等常用组件等。 swoolefy swoolefy是一个基于swoole扩展实现的轻量级高性能的常驻内存型的API和Web应用服务框架,高度封装了http，websocket，ud...

lewinlee 2019-06-28 18:17 评论0 收藏0
PHP下用Swoole实现Actor并发模型

摘要：协程与信箱得益于，我们可以基于的协程与快速实现一个信箱模式调度。样例代码比如在一个聊天室中，我们可以定义一个房间模型。什么是Actor？ Actor对于PHPer来说，可能会比较陌生，写过Java的同学会比较熟悉，Java一直都有线程的概念（虽然PHP有Pthread,但不普及）,它是一种非共享内存的并发模型，每个Actor内的数据独立存在，Actor之间通过消息传递的形式进行交互调...

GeekQiaQia 2019-07-01 13:56 评论0 收藏0
聊聊 2018 年后端技术趋势

摘要：现在在后端业务开发编程方面，技术力量强的团队已经开始将技术栈从同步模式切换为异步了。使用这些技术方案是无法兼容已有程序的。影响了异步回调技术栈的普及。将会成为未来后端开发领域的主流技术方案。今天太忙，少写一点，后面再补充。异步模式 Go 语言越来越热门，很多大型互联网公司后端正在转向 GO 。Java 圈知名的服务化框架 Dubbo 也宣布转型异步模式。这是一个大趋势，异步模式已经...

Miyang 2019-06-28 18:19 评论0 收藏0