Generator implements Iterator {
 public mixed current ( void ) // 返回當(dāng)前產(chǎn)生的值
 public mixed key ( void ) // 返回當(dāng)前產(chǎn)生的鍵
 public void next ( void ) // 生成器繼續(xù)執(zhí)行
 public void rewind ( void ) // 重置迭代器，如果迭代已經(jīng)開始了，這里會拋出一個異常。
   // renwind的執(zhí)行將會導(dǎo)致第一個yield被執(zhí)行, 并且忽略了他的返回值.
 public mixed send ( mixed $value ) // 向生成器中傳入一個值，并且當(dāng)做 yield 表達式的結(jié)果，然后繼續(xù)執(zhí)行生成器。如果當(dāng)這個方法被調(diào)用時，生成器 
   // 不在 yield 表達式，那么在傳入值之前，它會先運行到第一個 yield 表達式。
 public void throw ( Exception $exception ) // 向生成器中拋入一個異常
 public bool valid ( void ) // 檢查迭代器是否被關(guān)閉
 public void __wakeup ( void ) // 序列化回調(diào)，拋出一個異常以表示生成器不能被序列化。
}

class timer {
 private $start = 0; // 定時開始時間
 private $timer; // 間隔的時間差，單位秒
 private $value = 0; // 產(chǎn)生的結(jié)果值
 private $callback; // 異步回調(diào)
 private $isEnd = false; // 當(dāng)前定時器任務(wù)是否結(jié)束
 public function __construct($timer,callable $callback)
 {
 $this->start = time();
 $this->timer = $timer;
 $this->callback = $callback;
 }
 public function run() {
 if($this->valid()) {
 $callback = $this->callback;
 $callback($this->value ++,$this);
 $this->start = time();
 }
 }
 /**
 * 定時執(zhí)行檢查
 */
 public function valid() {
 $end = time();
 if($end - $this->start >= $this->timer) {
 return true;
 } else {
 return false;
 }
 }
 public function setEnd($isEnd) {
 $this->isEnd = $isEnd;
 }
 public function getEnd() {
 return $this->isEnd;
 }
}

/**
 * 模擬阻塞的協(xié)程1
 *
 */
function taskObject1() {
 $timer = new timer(1,function($value,timer $timer) {
 if($value >= 5) {
 $timer->setEnd(true);
 }
 echo '<br>'.'A '.$value;
 });
 $tid = (yield getTaskId());
 while (true) {
 if($timer->getEnd() == true) {
 break;
 }
 yield $timer->run();
 }
}
/**
 * 模擬阻塞的協(xié)程2
 *
 */
function taskObject2() {
 $timer = new timer(2,function($value,timer $timer) {
 if($value >= 3) {
 $timer->setEnd(true);
 }
 echo '<br>'.'B '.$value;
 });
 $tid = (yield getTaskId());
 while (true) {
 if($timer->getEnd() == true) {
 break;
 }
 yield $timer->run();
 }
}
$scheduler = new Scheduler;
$scheduler->newTask(taskObject1());
$scheduler->newTask(taskObject2());
$scheduler->run();

// 一個簡單的例子
<?php
function xrange($start, $end, $step = 1) {
 for ($i = $start; $i <= $end; $i += $step) {
 yield $i;
 }
}
 
foreach (xrange(1, 1000000) as $num) {
 echo $num, "\n";
}