资讯专栏INFORMATION COLUMN

PHP7中生成器的新特性 yield-from && return-values

pinecone / 3190人阅读

摘要:生成器委托简单地翻译官方文档的描述中,通过生成器委托,可以将其他生成器可迭代的对象数组委托给外层生成器。外层的生成器会先顺序委托出来的值,然后继续本身中定义的值。文章介绍了的迭代生成器,协程,并实现了一个简单的非阻塞服务器。

生成器委托

简单地翻译官方文档的描述:

PHP7中,通过生成器委托(yield from),可以将其他生成器、可迭代的对象、数组委托给外层生成器。外层的生成器会先顺序 yield 委托出来的值,然后继续 yield 本身中定义的值。

利用 yield from 可以方便我们编写比较清晰生成器嵌套,而代码嵌套调用是编写复杂系统所必需的。
上例子:


以上将输出:

foo iteration 1
foo iteration 2
foo iteration 3
foo iteration 4
foo iteration 5
foo iteration 6
foo iteration 7
foo iteration 8
foo iteration 9
foo iteration 10
---
bar iteration 1
bar iteration 2
bar iteration 3
bar iteration 4
bar iteration 5

自然,内部生成器也可以接受它的父生成器发送的信息或者异常,因为 yield from 为父子生成器建立一个双向的通道。不多说,上例子:

send($num);
}
$gen->send(null);
foreach (range(1,5) as $num) {
    $gen->send($num);
}
//$gen->send("hello world"); //try it ,gay

输出和上个例子是一样的。

生成器返回值

如果生成器被迭代完成,或者运行到 return 关键字,是会给这个生成器返回值的。
可以有两种方法获取这个返回值:

使用 $ret = Generator::getReturn() 方法。

使用 $ret = yield from Generator() 表达式。

上例子:

getReturn();
}

foreach (task() as $item) {
    ;
}

输出结果就不贴了,想必大家都猜到。

可以看到 yield from 和 return 结合使得 yield 的写法更像平时我们写的同步模式的代码了,毕竟,这就是 PHP 出生成器特性的原因之一呀。

一个非阻塞的web服务器

时间回到2015年,鸟哥博客上转载的一篇《 在PHP中使用协程实现多任务调度》。文章介绍了PHP5 的迭代生成器,协程,并实现了一个简单的非阻塞 web 服务器。(链接见文末引用)

现在我们利用 PHP7 中的这两个新特性重写这个 web 服务器,只需要 100 多行代码。

代码如下:

socket = $socket;
        $this->masterCoSocket = $master ?? $this;
    }

    public function accept()
    {
        $isSelect = yield from $this->onRead();
        $acceptS = null;
        if ($isSelect && $as = stream_socket_accept($this->socket, 0)) {
            $acceptS = new CoSocket($as, $this);
        }
        return $acceptS;
    }

    public function read($size)
    {
        yield from $this->onRead();
        yield ($data = fread($this->socket, $size));
        return $data;
    }

    public function write($string)
    {
        yield from $this->onWriter();
        yield fwrite($this->socket, $string);
    }

    public function close()
    {
        unset($this->masterCoSocket->streamPoolRead[(int)$this->socket]);
        unset($this->masterCoSocket->streamPoolWrite[(int)$this->socket]);
        yield ($success = @fclose($this->socket));
        return $success;
    }

    public function onRead($timeout = null)
    {
        $this->masterCoSocket->streamPoolRead[(int)$this->socket] = $this->socket;
        $pool = $this->masterCoSocket->streamPoolRead;
        $rSocks = [];
        $wSocks = $eSocks = null;
        foreach ($pool as $item) {
            $rSocks[] = $item;
        }
        yield ($num = stream_select($rSocks, $wSocks, $eSocks, $timeout));
        return $num;
    }

    public function onWriter($timeout = null)
    {
        $this->masterCoSocket->streamPoolWrite[(int)$this->socket] = $this->socket;
        $pool = $this->masterCoSocket->streamPoolRead;
        $wSocks = [];
        $rSocks = $eSocks = null;
        foreach ($pool as $item) {
            $wSocks[] = $item;
        }
        yield ($num = stream_select($rSocks, $wSocks, $eSocks, $timeout));
        return $num;
    }

    public function onRequest()
    {
        /** @var self $socket */
        $socket = yield from $this->accept();
        if (empty($socket)) {
            return false;
        }
        $data = yield from $socket->read(8192);
        $response = call_user_func($this->handleCallback, $data);
        yield from $socket->write($response);
        return yield from $socket->close();
    }

    public static function start($port, callable $callback)
    {
        echo "Starting server at port $port...
";
        $socket = @stream_socket_server("tcp://0.0.0.0:$port", $errNo, $errStr);
        if (!$socket) throw new Exception($errStr, $errNo);
        stream_set_blocking($socket, 0);
        $coSocket = new self($socket);
        $coSocket->handleCallback = $callback;
        function gen($coSocket)
        {
            /** @var self $coSocket */
            while (true) yield from $coSocket->onRequest();
        }
        foreach (gen($coSocket) as $item){};
    }
}

CoSocket::start(8000, function ($data) {
    $response = <<
参考资料

[1] http://www.php.net/manual/zh/...

[2] http://www.laruence.com/2015/...

[3] http://blog.csdn.net/u0101613...

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

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

相关文章

  • PHP 7.0 &amp; 7.1 部分新增特性备忘

    摘要:以下分别备忘版本的部分新增特性。而且,在生成器没有输出完全时,使用会报错。报错定义常量数组多声明数组解构运行时将部分指令转为机器码。对于计算密集型应用有较高的性能提升。 以下分别备忘 PHP 7.0 & 7.1 版本的部分新增特性。 PHP 7.0 ?? 运算符 $foo = null; $bar = $foo ?? 123; // 相当于 $bar = isset($bar) ? ...

    philadelphia 评论0 收藏0
  • PHP 生成器入门

    摘要:执行语句的唯一目的是结束生成器执行。这就是需要生成器需要有返回值的意义,这也是为何我们将这个特性加入到中的原因,我们会将最后执行的值作为返回值,但这不是一个好的解决方案。 本文首发于 入门 PHP 生成器,转载请注明出处。 PHP 在 5.5 版本中引入了「生成器(Generator)」特性,不过这个特性并没有引起人们的注意。在官方的 从 PHP 5.4.x 迁移到 PHP 5.5.x...

    IamDLY 评论0 收藏0
  • python中的生成器、迭代器、装饰器分别是什么意思呢?

      python中的生成器、迭代器、装饰器分别是什么意思呢?具体的含义,一些其具体的用途,下面小编就给大家详细的解答下。  一、装饰器  由于一个函数能实现一种功能,现在想要在不改变其代码的情况下,让这个函数进化一下,即能保持原来的功能,还能有新的"技能",怎么办?  现已经存在一个自定义的函数func1  deffunc1():   print('hello,worl...

    89542767 评论0 收藏0
  • async &amp; await &amp; promise

    摘要:最近项目中用的比较多,所以特地去了解,模仿一下实现先来看看使用的方法通过是通过使用生成器配合方法模拟的一个同步操作,这个技术有效的避免了传统回调和形成的回调地狱。 最近项目中 asyn & await 用的比较多,所以特地去了解,模仿一下实现~ 先来看看 使用 async & await 的方法 async function d () { try { const a = a...

    Dean 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<