生成器委托 簡單地翻譯官方文檔的描述： PHP7中，通過生成器委托（yield from），可以將其他生成器、可迭代的對象、數組委托給外層生成器。外層的生成器會先順序 yield 委托出來的值，然后繼續 yield 本身中定義的值。 利用 yield from 可以方便我們編寫比較清晰生成器嵌套，而代碼嵌套調用是編寫復雜系統所必需的。 上例子： ~~~ <?php function echoTimes($msg, $max) { for ($i = 1; $i <= $max; ++$i) { echo "$msg iteration $i\n"; yield; } } function task() { yield from echoTimes('foo', 10); // print foo ten times echo "---\n"; yield from echoTimes('bar', 5); // print bar five times } foreach (task() as $item) { ; } ~~~ 以上將輸出： ~~~ 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 為父子生成器建立一個雙向的通道。不多說，上例子： ~~~ <?php function echoMsg($msg) { while (true) { $i = yield; if($i === null){ break; } if(!is_numeric($i)){ throw new Exception("Hoo! must give me a number"); } echo "$msg iteration $i\n"; } } function task2() { yield from echoMsg('foo'); echo "---\n"; yield from echoMsg('bar'); } $gen = task2(); foreach (range(1,10) as $num) { $gen->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() 表達式。 上例子： ~~~ <?php function echoTimes($msg, $max) { for ($i = 1; $i <= $max; ++$i) { echo "$msg iteration $i\n"; yield; } return "$msg the end value : $i\n"; } function task() { $end = yield from echoTimes('foo', 10); echo $end; $gen = echoTimes('bar', 5); yield from $gen; echo $gen->getReturn(); } foreach (task() as $item) { ; } ~~~ 輸出結果就不貼了，想必大家都猜到。 可以看到 yield from 和 return 結合使得 yield 的寫法更像平時我們寫的同步模式的代碼了，畢竟，這就是 PHP 出生成器特性的原因之一呀。 一個非阻塞的web服務器 時間回到2015年，鳥哥博客上轉載的一篇《 在PHP中使用協程實現多任務調度》。文章介紹了PHP5 的迭代生成器，協程，并實現了一個簡單的非阻塞 web 服務器。 現在我們利用 PHP7 中的這兩個新特性重寫這個 web 服務器，只需要 100 多行代碼。 代碼如下： ~~~ <?php class CoSocket { protected $masterCoSocket = null; public $socket; protected $handleCallback; public $streamPoolRead = []; public $streamPoolWrite = []; public function __construct($socket, CoSocket $master = null) { $this->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; ~~~