PHP 协程:Go + Chan + Defer

Swoole4PHP语言提供了强大的CSP协程编程模式。底层提供了3个关键词,可以方便地实现各类功能。

  • Swoole4提供的PHP协程语法借鉴自Golang,在此向GO开发组致敬
  • PHP+Swoole协程可以与Golang很好地互补。Golang:静态语言,严谨强大性能好,PHP+Swoole:动态语言,灵活简单易用

本文基于Swoole-4.2.9PHP-7.2.9版本

关键词

  • go :创建一个协程
  • chan :创建一个通道
  • defer :延迟任务,在协程退出时执行,先进后出

3个功能底层实现全部为内存操作,没有任何IO资源消耗。就像PHPArray一样是非常廉价的。如果有需要就可以直接使用。这与socketfile操作不同,后者需要向操作系统申请端口和文件描述符,读写可能会产生阻塞的IO等待。

协程并发

使用go函数可以让一个函数并发地去执行。在编程过程中,如果某一段逻辑可以并发执行,就可以将它放置到go协程中执行。

顺序执行

function test1()
{
    sleep(1);
    echo "b";
}

function test2()
{
    sleep(2);
    echo "c";
}

test1();
test2();

执行结果:

[email protected]:~$ time php b1.php bc real 0m3.080s user 0m0.016s sys 0m0.063s [email protected]:~$

上述代码中,test1test2会顺序执行,需要3秒才能执行完成。

并发执行

使用go创建协程,可以让test1test2两个函数变成并发执行。

Swoole\Runtime::enableCoroutine();

go(function ()
{
    sleep(1);
    echo "b";
});

go(function ()
{
    sleep(2);
    echo "c";
});

Swoole\Runtime::enableCoroutine()作用是将PHP提供的streamsleeppdomysqliredis等功能从同步阻塞切换为协程的异步IO

执行结果:

[email protected]:~$ time php co.php
bc
real    0m2.076s
user    0m0.000s
sys     0m0.078s
[email protected]:~$

可以看到这里只用了2秒就执行完成了。

  • 顺序执行耗时等于所有任务执行耗时的总和 :t1+t2+t3...
  • 并发执行耗时等于所有任务执行耗时的最大值 :max(t1, t2, t3, ...)

协程通信

有了go关键词之后,并发编程就简单多了。与此同时又带来了新问题,如果有2个协程并发执行,另外一个协程,需要依赖这两个协程的执行结果,如果解决此问题呢?

答案就是使用通道(Channel),在Swoole4协程中使用new chan就可以创建一个通道。通道可以理解为自带协程调度的队列。它有两个接口pushpop

  • push:向通道中写入内容,如果已满,它会进入等待状态,有空间时自动恢复
  • pop:从通道中读取内容,如果为空,它会进入等待状态,有数据时自动恢复

使用通道可以很方便地实现并发管理

$chan = new chan(2);

# 协程1
go (function () use ($chan) {
    $result = [];
    for ($i = 0; $i < 2; $i++)
    {
        $result += $chan->pop();
    }
    var_dump($result);
});

# 协程2
go(function () use ($chan) {
   $cli = new Swoole\Coroutine\Http\Client(‘www.qq.com‘, 80);
       $cli->set([‘timeout‘ => 10]);
       $cli->setHeaders([
       ‘Host‘ => "www.qq.com",
       "User-Agent" => ‘Chrome/49.0.2587.3‘,
       ‘Accept‘ => ‘text/html,application/xhtml+xml,application/xml‘,
       ‘Accept-Encoding‘ => ‘gzip‘,
   ]);
   $ret = $cli->get(‘/‘);
   // $cli->body 响应内容过大,这里用 Http 状态码作为测试
   $chan->push([‘www.qq.com‘ => $cli->statusCode]);
});

# 协程3
go(function () use ($chan) {
   $cli = new Swoole\Coroutine\Http\Client(‘www.163.com‘, 80);
   $cli->set([‘timeout‘ => 10]);
   $cli->setHeaders([
       ‘Host‘ => "www.163.com",
       "User-Agent" => ‘Chrome/49.0.2587.3‘,
       ‘Accept‘ => ‘text/html,application/xhtml+xml,application/xml‘,
       ‘Accept-Encoding‘ => ‘gzip‘,
   ]);
   $ret = $cli->get(‘/‘);
   // $cli->body 响应内容过大,这里用 Http 状态码作为测试
   $chan->push([‘www.163.com‘ => $cli->statusCode]);
});

执行结果:

```[email protected]:~/swoole-src/examples/5.0$ time php co2.php

array(2) {

["www.qq.com"]=>

int(302)

["www.163.com"]=>

int(200)

}

real 0m0.268s

user 0m0.016s

sys 0m0.109s

[email protected]:~/swoole-src/examples/5.0$


<p>这里使用<code>go</code>创建了<code>3</code>个协程,协程<code>2</code>和协程<code>3</code>分别请求<code>qq.com</code>和<code>163.com</code>主页。协程<code>1</code>需要拿到<code>Http</code>请求的结果。这里使用了<code>chan</code>来实现并发管理。</p>
<ul>
<li>协程<code>1</code>循环两次对通道进行<code>pop</code>,因为队列为空,它会进入等待状态</li>
<li>协程<code>2</code>和协程<code>3</code>执行完成后,会<code>push</code>数据,协程<code>1</code>拿到了结果,继续向下执行</li>
</ul>
<h1>延迟任务</h1>
<p>在协程编程中,可能需要在协程退出时自动实行一些任务,做清理工作。类似于<code>PHP</code>的<code>register_shutdown_function</code>,在<code>Swoole4</code>中可以使用<code>defer</code>实现。</p>

Swoole\Runtime::enableCoroutine();

go(function () {

echo "a";

defer(function () {

echo "~a";

});

echo "b";

defer(function () {

echo "~b";

});

sleep(1);

echo "c";

});


<h4>执行结果:</h4>

[email protected]:~/swoole-src/examples/5.0$ time php defer.php

abc~b~a

real 0m1.068s

user 0m0.016s

sys 0m0.047s

[email protected]:~/swoole-src/examples/5.0$

```

结语

Swoole4提供的Go + Chan + DeferPHP带来了一种全新的CSP并发编程模式。灵活使用Swoole4提供的各项特性,可以解决工作中各类复杂功能的设计和开发。

原文地址:https://segmentfault.com/a/1190000017243966

原文地址:https://www.cnblogs.com/lovellll/p/10110612.html

时间: 2024-11-07 05:00:20

PHP 协程:Go + Chan + Defer的相关文章

go 利用chan的阻塞机制,实现协程的开始、阻塞、返回控制器

一.使用场景 大背景是从kafka 中读取oplog进行增量处理,但是当我想发一条命令将这个增量过程阻塞,然后开始进行一次全量同步之后,在开始继续增量. 所以需要对多个协程进行控制. 二.使用知识 1. 从一个未初始化的管道读会阻塞 2.从一个关闭的管道读不会阻塞 利用两个管道和select 进行控制 三.上代码 控制器代码 package util import ( "errors" "sync" ) const ( //STOP 停止 STOP = iota /

golang的多协程实践

go语言以优异的并发特性而闻名,刚好手上有个小项目比较适合. 项目背景: 公司播控平台的数据存储包括MySQL和ElasticSearch(ES)两个部分,编辑.运营的数据首先保存在MySQL中,为了实现模糊搜索和产品关联推荐,特别增加了ES,ES中保存的是节目集的基本信息. 本项目是为了防止实时同步数据出现问题或者系统重新初始化时的全量数据同步而做的.项目主要是从MySQL读取所有的节目集数据写入到ES中. 项目特点: 因为节目集数量较大,不能一次性的读入内存,因此每次读出一部分记录写入ES.

GoLang之协程

GoLang之协程 目前,WebServer几种主流的并发模型: 多线程,每个线程一次处理一个请求,在当前请求处理完成之前不会接收其它请求:但在高并发环境下,多线程的开销比较大: 基于回调的异步IO,如Nginx服务器使用的epoll模型,这种模式通过事件驱动的方式使用异步IO,使服务器持续运转,但人的思维模式是串行的,大量回调函数会把流程分割,对于问题本身的反应不够自然: 协程,不需要抢占式调度,可以有效提高线程的任务并发性,而避免多线程的缺点:但原生支持协程的语言还很少. 协程(corout

golang中四种方式实现子goroutine与主协程的同步

如何实现子goroutine与主线程的同步 第一种方式:time.sleep(),这种方式很太死板,就不演示了. 第二种方式:使用channel机制,每个goroutine传一个channel进去然后往里写数据,在再主线程中读取这些channel,直到全部读到数据了子goroutine也就全部运行完了,那么主goroutine也就可以结束了.这种模式是子线程去通知主线程结束. package main import ( "fmt" ) func main() { var chanTes

golang协程同步的几种方法

目录 golang协程同步的几种方法 协程概念简要理解 为什么要做同步 协程的几种同步方法 Mutex channel WaitGroup golang协程同步的几种方法 本文简要介绍下go中协程的几种同步方法. 协程概念简要理解 协程类似线程,是一种更为轻量级的调度单位,但协程还是不同于线程的,线程是系统级实现的,常见的调度方法是时间片轮转法,如每隔10ms切换一个线程执行. 协程则是应用软件级实现,它和线程的原理差不多,当一个协程调度到另一个协程时,将上一个协程的上下文信息压入堆栈,来回切换

理解Go协程与并发

协程 Go语言里创建一个协程很简单,使用go关键字就可以让一个普通方法协程化: package main import ( "fmt" "time" ) func main(){ fmt.Println("run in main coroutine.") for i:=0; i<10; i++ { go func(i int) { fmt.Printf("run in child coroutine %d.\n", i)

go语言协程安全map

前言: 在go语言中 map 是很重要的数据结构.Map 是一种无序的键值对的集合.Map 最重要的一点是通过 key 来快速检索数据,key 类似于索引,指向数据的值.问题来了,这么安逸的 数据结构,它不是协程安全的 !当多个 协程同时对一个map 进行 读写时,会抛出致命错误.总结一下 想要 做到 协程安全 map 一共有以下三种方法. 1.map + 锁 这是最常见的一种操作,当要对 map操作的时候就加锁,其他的 协程就等待.下面是代码示例: package util import "s

面试必问:Golang高阶-Golang协程实现原理

引言 实现并发编程有进程,线程,IO多路复用的方式.(并发和并行我们这里不区分,如果CPU是多核的,可能在多个核同时进行,我们叫并行,如果是单核,需要排队切换,我们叫并发) 进程和线程的区别 进程是计算机资源分配的最小单位,进程是对处理器资源(CPU),虚拟内存(1)的抽象, 虚拟内存是对主存资源(Memory)和文件(2)的抽象,文件是对I/O设备的抽象. 虚拟内存是操作系统初始化后内部维护的一个程序加载空间,对于32位操作系统来说,也就是寄存器有32位的比特长度,虚拟内存中每个字节都有一个内

golang协程——通道channel阻塞

新的一年开始了,不管今天以前发生了什么,向前看,就够了. 说到channel,就一定要说一说线程了.任何实际项目,无论大小,并发是必然存在的.并发的存在,就涉及到线程通信.在当下的开发语言中,线程通讯主要有两种,共享内存与消息传递.共享内存一定都很熟悉,通过共同操作同一对象,实现线程间通讯.消息传递即通过类似聊天的方式.golang对并发的处理采用了协程的技术.golang的goroutine就是协程的实现.协程的概念很早就有,简单的理解为轻量级线程,goroutine就是为了解决并发任务间的通