php实现协程，真正的异步

博主： dafenqi
发布时间：2023 年 08 月 10 日
82 次浏览
暂无评论
353字数
分类： php 代码片段

# [php实现协程，真正的异步](https://blog.csdn.net/llj1985/article/details/51684210) 
github上php的协程大部分是根据这篇文章实现的：http://nikic.github.io/2012/12/22/Cooperative-multitasking-using-coroutines-in-PHP.html。

它们最终的结果都是把回调变成了优雅的顺序执行的代码，但还是阻塞的，不是真正的异步。

比如最热门的：https://github.com/recoilphp/recoil

先安装：
```php
composer require recoil/recoil：
```

执行：

```php
<?php
//recoil.php

include __DIR__ . '/vendor/autoload.php';

use Recoil\React\ReactKernel;

$i = 100000;

ReactKernel::start(task1());
ReactKernel::start(task2());

function task1(){
    global $i;
    echo "wait start" . PHP_EOL;
    while ($i-- > 0) {
        yield;
    }
    echo "wait end" . PHP_EOL;
};

function task2(){
    echo "Hello " . PHP_EOL;
    yield;
    echo "world!" . PHP_EOL;
}
```php

> 结果：
> wait start
> //等待若干秒
> wait end
> Hello
> world!

我本来是想让两个任务并行，结果两个任务变成了串行，中间等待的时间什么事情都干不了。React响应式的编程是严格禁止这种等待的，所以我就参照unity3d的协程自己写了个php版本的。上代码：

```php
<?php
//Coroutine.php
//依赖swoole实现的定时器，也可以用其它方法实现定时器

class Coroutine
{
    //可以根据需要更改定时器间隔，单位ms
    const TICK_INTERVAL = 1;

private $routineList;

private $tickId = -1;

public function __construct()
    {
        $this->routineList = [];
    }

public function start(Generator $routine)
    {
        $task = new Task($routine);
        $this->routineList[] = $task;
        $this->startTick();
    }

public function stop(Generator $routine)
    {
        foreach ($this->routineList as $k => $task) {
            if($task->getRoutine() == $routine){
                unset($this->routineList[$k]);
            }
        }
    }

private function startTick()
    {
        swoole_timer_tick(self::TICK_INTERVAL, function($timerId){
            $this->tickId = $timerId;
            $this->run();
        });
    }

private function stopTick()
    {
        if($this->tickId >= 0) {
            swoole_timer_clear($this->tickId);
        }
    }

private function run()
    {
        if(empty($this->routineList)){
            $this->stopTick();
            return;
        }

foreach ($this->routineList as $k => $task) {
            $task->run();

if($task->isFinished()){
                unset($this->routineList[$k]);
            }
        }
    }
    
}

class Task
{
    protected $stack;
    protected $routine;

public function __construct(Generator $routine)
    {
        $this->routine = $routine;
        $this->stack = new SplStack();
    }

/**
     * [run 协程调度]
     * @return [type]         [description]
     */
    public function run()
    {
        $routine = &$this->routine;

try {

if(!$routine){
                return;
            }

$value = $routine->current();

//嵌套的协程
            if ($value instanceof Generator) {
                $this->stack->push($routine);
                $routine = $value;
                return;
            }

//嵌套的协程返回
            if(!$routine->valid() && !$this->stack->isEmpty()) {
                $routine = $this->stack->pop();
            }

$routine->next();

} catch (Exception $e) {

if ($this->stack->isEmpty()) {
                /*
                    throw the exception 
                */
                return;
            }
        }
    }

/**
     * [isFinished 判断该task是否完成]
     * @return boolean [description]
     */
    public function isFinished()
    {
        return $this->stack->isEmpty() && !$this->routine->valid();
    }

public function getRoutine()
    {
        return $this->routine;
    }
}
```

测试代码：

```php
<?php
//test.php

require 'Coroutine.php';

$i = 10000;

$c = new Coroutine();
$c->start(task1());
$c->start(task2());

function task1(){
    global $i;
    echo "wait start" . PHP_EOL;
    while ($i-- > 0) {
        yield;
    }
    echo "wait end" . PHP_EOL;
};

function task2(){
    echo "Hello " . PHP_EOL;
    yield;
    echo "world!" . PHP_EOL;
}
```

> 结果：
> wait start
> Hello
> world!
> //等待几秒，但不阻塞
> wait end

**注：此文章需要验证。**

最后修改：2023 年 08 月 10 日

如果觉得我的文章对你有用，请随意赞赏

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

评论 *

私密评论

名称 *

🎲

邮箱 *

地址

zodhzrusdp
《遥遥乡愁》剧情片高清在线免费观看：https://www.j...
jprfffedhg
你的才华让人瞩目，期待你的更多文章。 https://w...
pkrqcpalxw
你的文章让我感受到了无尽的欢乐，谢谢分享。 http:/...
urjitfqbzy
你的文章让我感受到了生活的美好，谢谢！ https://...
bfgsfrpbas
你的文章让我心情愉悦，每天都要来看一看。 https:/...

php实现协程，真正的异步

dafenqi • 2023 年 08 月 10 日

它们最终的结果都是把回调变成了优雅的顺序执行的代码，但还是阻塞的，不是真正的异步。

比如最热门的：https://github.com/recoilphp/recoil

先安装：
```php
composer require recoil/recoil：
```

执行：

```php
<?php
//recoil.php

include __DIR__ . '/vendor/autoload.php';

use Recoil\React\ReactKernel;

$i = 100000;

ReactKernel::start(task1());
ReactKernel::start(task2());

function task1(){
    global $i;
    echo "wait start" . PHP_EOL;
    while ($i-- > 0) {
        yield;
    }
    echo "wait end" . PHP_EOL;
};

function task2(){
    echo "Hello " . PHP_EOL;
    yield;
    echo "world!" . PHP_EOL;
}
```php

> 结果：
> wait start
> //等待若干秒
> wait end
> Hello
> world!

```php
<?php
//Coroutine.php
//依赖swoole实现的定时器，也可以用其它方法实现定时器

class Coroutine
{
    //可以根据需要更改定时器间隔，单位ms
    const TICK_INTERVAL = 1;

private $routineList;

private $tickId = -1;

public function __construct()
    {
        $this->routineList = [];
    }

public function start(Generator $routine)
    {
        $task = new Task($routine);
        $this->routineList[] = $task;
        $this->startTick();
    }

private function startTick()
    {
        swoole_timer_tick(self::TICK_INTERVAL, function($timerId){
            $this->tickId = $timerId;
            $this->run();
        });
    }

private function stopTick()
    {
        if($this->tickId >= 0) {
            swoole_timer_clear($this->tickId);
        }
    }

private function run()
    {
        if(empty($this->routineList)){
            $this->stopTick();
            return;
        }

foreach ($this->routineList as $k => $task) {
            $task->run();

if($task->isFinished()){
                unset($this->routineList[$k]);
            }
        }
    }
    
}

class Task
{
    protected $stack;
    protected $routine;

public function __construct(Generator $routine)
    {
        $this->routine = $routine;
        $this->stack = new SplStack();
    }

/**
     * [run 协程调度]
     * @return [type]         [description]
     */
    public function run()
    {
        $routine = &$this->routine;

try {

if(!$routine){
                return;
            }

$value = $routine->current();

//嵌套的协程
            if ($value instanceof Generator) {
                $this->stack->push($routine);
                $routine = $value;
                return;
            }

//嵌套的协程返回
            if(!$routine->valid() && !$this->stack->isEmpty()) {
                $routine = $this->stack->pop();
            }

$routine->next();

} catch (Exception $e) {

if ($this->stack->isEmpty()) {
                /*
                    throw the exception 
                */
                return;
            }
        }
    }

public function getRoutine()
    {
        return $this->routine;
    }
}
```

测试代码：

```php
<?php
//test.php

require 'Coroutine.php';

$i = 10000;

$c = new Coroutine();
$c->start(task1());
$c->start(task2());

function task1(){
    global $i;
    echo "wait start" . PHP_EOL;
    while ($i-- > 0) {
        yield;
    }
    echo "wait end" . PHP_EOL;
};

function task2(){
    echo "Hello " . PHP_EOL;
    yield;
    echo "world!" . PHP_EOL;
}
```

> 结果：
> wait start
> Hello
> world!
> //等待几秒，但不阻塞
> wait end

**注：此文章需要验证。**

php实现协程，真正的异步

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

PHP 数据类型

当你在浏览器扣下域名时。。。

PHP switch 替代品 match

变量在内存中的表现形式

简易发邮件

nginx 手册

PHP Session可能会引起并发问题

如何通过php代码测试功能防止代码中的安全漏洞

对接支付宝接口时异步回调和同步回调的区别与作用！

linux不可不知的几个常用命令

php实现协程，真正的异步

发表评论 取消回复 使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

php实现协程，真正的异步

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款