异常: 嵌套任务透传

重新处理生成器嵌套，需要将子生成器异常抛向父生成器。

当生成器迭代过程发生未捕获异常，生成器将会被关闭，Generator::valid返回false，未捕获异常会从生成器内部被抛向父作用域，嵌套子生成器内部的未捕获异常必须最终被抛向根生成器的calling frame，PHP7中yield-from对嵌套子生成器resume时产生的异常，采取goto try_again传递+while方式层层向上抛出，我们的代码因为递归迭代的原因，未捕获异常需要逆递归栈帧方向层层上抛，性能方便有改进余地。

  1. <?php
  3. final class AsyncTask
  4. {
  5.     public function next($result = null, \Exception $ex = null)
  6.     {
  7.         try {
  8.             if ($ex) {
  9.                 // c. 直接抛出异常
  10.                 // $ex来自子生成器， 调用父生成器throw抛出
  11.                 // 这里实现了 try { yield \Generator; } catch(\Exception $ex) { }
  12.                 // echo "c -> ";
  13.                 $value = $this->gen->throw_($ex);
  14.             } else {
  15.                 // a2. 当前生成器可能抛出异常
  16.                 // echo "a2 -> ";
  17.                 $value = $this->gen->send($result);
  18.             }
  20.             if ($this->gen->valid()) {
  21.                 if ($value instanceof \Generator) {
  22.                     // a3. 子生成器可能抛出异常
  23.                     // echo "a3 -> ";
  24.                     $value = (new self($value))->begin();
  25.                 }
  26.                 // echo "a4 -> ";
  27.                 return $this->next($value);
  28.             } else {
  29.                 return $result;
  30.             }
  31.         } catch (\Exception $ex) {
  32.             // !! 当生成器迭代过程发生未捕获异常， 生成器将会被关闭， valid()返回false,
  33.             if ($this->gen->valid()) {
  34.                 // b1. 所以， 当前分支的异常一定不是当前生成器所抛出， 而是来自嵌套的子生成器
  35.                 // 此处将子生成器异常通过(c)向当前生成器抛出异常
  36.                 // echo "b1 -> ";
  37.                 return $this->next(null, $ex);
  38.             } else {
  39.                 // b2. 逆向(递归栈帧)方向向上抛 或者 向父生成器(如果存在)抛出异常
  40.                 // echo "b2 -> ";
  41.                 throw $ex;
  42.             }
  43.         }
  44.     }
  45. }
  1. <?php
  2. function newSubGen()
  3. {
  4.     yield 0;
  5.     throw new \Exception("e");
  6.     yield 1;
  7. }
  9. function newGen()
  10. {
  11.     try {
  12.         $r1 = (yield newSubGen());
  13.     } catch (\Exception $ex) {
  14.         echo $ex->getMessage();
  15.     }
  16.     $r2 = (yield 2);
  17.     yield 3;
  18. }
  19. $task = new AsyncTask(newGen());
  20. $r = $task->begin(); // output: e
  21. echo $r; // output: 3