引入异常处理

尽管只有寥寥几行代码，我们却已经实现了可工作的半协程调度器(缺失异常处理)。

没关系，下面先rollback回return的实现，开始引入异常处理，目标是在嵌套生成器之间正确向上抛出异常，跨生成器捕获异常。

  1. <?php
  3. // 为Gen引入throw方法
  4. class Gen
  5. {
  6.     // PHP7 之前 关键词不能用作名字
  7.     public function throw_(\Exception $ex)
  8.     {
  9.         return $this->generator->throw($ex);
  10.     }
  11. }
  13. final class AsyncTask
  14. {
  15.     public function begin()
  16.     {
  17.         return $this->next();
  18.     }
  20.     // 这里添加第二个参数， 用来在迭代过程传递异常
  21.     public function next($result = null, \Exception $ex = null)
  22.     {
  23.         if ($ex) {
  24.             $this->gen->throw_($ex);
  25.         }
  27.         $ex = null;
  28.         try {
  29.             // send方法内部是一个resume的过程: 
  30.             // 恢复execute_data上下文， 调用zend_execute_ex()继续执行,
  31.             // 后续中op_array内可能会抛出异常
  32.             $value = $this->gen->send($result);
  33.         } catch (\Exception $ex) {}
  35.         if ($ex) {
  36.             if ($this->gen->valid()) {
  37.                 // 传递异常
  38.                 return $this->next(null, $ex);
  39.             } else {
  40.                 throw $ex;
  41.             }
  42.         } else {
  43.             if ($this->gen->valid()) {
  44.                 // 正常yield值
  45.                 return $this->next($value);
  46.             } else {
  47.                 return $result;
  48.             }
  49.         }
  50.     }
  51. }
  1. <?php
  2. function newGen()
  3. {
  4.     $r1 = (yield 1);
  5.     throw new \Exception("e");
  6.     $r2 = (yield 2);
  7.     yield 3;
  8. }
  9. $task = new AsyncTask(newGen());
  10. try {
  11.     $r = $task->begin();
  12.     echo $r;
  13. } catch (\Exception $ex) {
  14.     echo $ex->getMessage(); // output: e
  15. }