PHP Fiber 怎样向挂起协程注入异常

在 PHP Fiber 中，外部调度器如果发现某个挂起任务已经失效，通常不应该继续调用 resume() 假装它还能正常完成，而是要把异常送回 Fiber 当前的暂停点。这个动作由 Fiber::throw(Throwable) 完成：异常会从当前的 Fiber::suspend() 调用处抛出，Fiber 内部可以用 try/catch 接住。

最重要的边界只有一个：调用 throw() 时 Fiber 必须正处于挂起状态。若 Fiber 没有挂起，PHP 会抛出 FiberError；若 Fiber 内没有捕获注入的异常，异常则会从 throw() 这次外部调用继续冒泡。

把 resume() 理解为“给挂起点一个返回值”，把 throw() 理解为“让挂起点抛出一个异常”。两者的入口不同，但都要求 Fiber 已经停在 Fiber::suspend() 上。

先建立一个明确的 Fiber 挂起点

Fiber 的外部代码只能在启动、恢复或注入异常之间做选择。下面的 Fiber 先把任务名交给调度器，再停在 Fiber::suspend()。因此，start() 返回后，外部持有的是一个已启动且已挂起的 Fiber。

start('导入任务');

此时不要根据变量名猜状态，调度器应当把“是否挂起”当成后续操作的前置条件。只对挂起的 Fiber 调用 resume() 或 throw()，可以避免把一个已经结束或仍在运行的 Fiber 当成等待中的任务。

Fiber::throw 究竟把异常送到哪里

Fiber::throw($exception) 不会在 Fiber 的任意位置凭空创建一个新的调用栈。它针对的是当前暂停的 Fiber::suspend()：从外部调用 throw() 后，Fiber 恢复执行，但暂停点不再返回普通值，而是直接抛出传入的 Throwable。

getMessage() . PHP_EOL;
    }
});

$fiber->start();

// 注入异常，异常的进入点就是上面的 Fiber::suspend()。
$fiber->throw(new RuntimeException('外部任务已取消'));

如果 catch 消化了异常，Fiber 可以继续执行清理逻辑并正常结束；如果没有捕获，RuntimeException 会从 $fiber->throw() 这一行抛出，外层调度器应当负责记录或转交。

不要把 resume 和 throw 当成同一种恢复

两种方法的差别可以压缩成一张表：

因此，超时和取消不应编码成一个特殊字符串再通过 resume() 传入。这样会迫使 Fiber 的业务代码在每个暂停点手动判断标记。使用 throw() 可以把失败交给正常的异常边界，清理和回滚逻辑也更容易集中在 catch 或 finally 中。

三种容易混淆的状态结果

Fiber 还没有挂起

如果刚创建的 Fiber 还没有调用 start()，或者 Fiber 已经恢复并运行到下一次挂起之前，此时调用 throw() 都不符合方法的状态要求。PHP 会抛出 FiberError，这不是注入到业务代码里的那个异常。

Fiber 内部捕获了异常

当 try/catch 覆盖住 Fiber::suspend()，注入的异常可以在 Fiber 内部转换成清理、重试或提前返回。外部的 throw() 可能因此正常返回；返回值取决于 Fiber 后续是否再次挂起或直接结束。

Fiber 没有捕获异常

未处理的异常会离开 Fiber，并从调用 throw() 的位置继续抛出。外层代码要把这次调用放在自己的异常边界内，而不是只检查 isTerminated()。状态查询只能告诉你生命周期状态，不能替代异常处理。

把异常注入放进调度器

在实际任务队列里，外部调度器通常会同时处理正常事件和取消事件。一个安全的最小封装是先检查 isSuspended()，再选择 resume() 或 throw()。这里的检查是状态门槛，不是对异常结果的替代。

isSuspended()) {
        throw new LogicException('Fiber 当前没有等待外部调度');
    }

    try {
        if ($failure !== null) {
            // 取消、超时或依赖失败使用异常通道传回 suspend()。
            $fiber->throw($failure);
            return;
        }

        // 普通事件走返回值通道，不和失败信号混用。
        $fiber->resume('继续处理');
    } catch (Throwable $exception) {
        // 未被 Fiber 内部捕获的异常在调度器边界统一记录或转交。
        error_log($exception->getMessage());
        throw $exception;
    }
}

这段封装有两个取舍。第一，isSuspended() 只能减少明显的状态误用，检查和调用之间仍应由同一个调度循环管理，不能把 Fiber 交给多个并发操作者。第二，重新抛出异常是为了让上层知道任务失败；如果业务决定吞掉异常，就应在更靠近任务边界的位置记录取消原因。

最后用状态和结果收尾

Fiber 正常返回后，可以使用 getReturn() 读取返回值；如果 Fiber 因未处理异常终止，则不能把它当成正常结果读取。对于取消路径，应该记录异常，再根据 isTerminated() 和任务状态决定是否从队列移除。

可以按下面的判断记忆：

• 想让 suspend() 返回普通数据，用 resume()。
• 想让 suspend() 进入异常处理，用 throw()。
• 想调用这两个方法，先确认 Fiber 处于 isSuspended()。
• 想读取正常返回值，等 isTerminated() 后再调用 getReturn()。

相关问题

Fiber::throw 可以在 Fiber 尚未 start 时调用吗？

不可以。Fiber 必须已经启动并停在 Fiber::suspend()，否则会得到 FiberError。

Fiber::throw 一定会让异常在外部抛出吗？

不一定。如果 Fiber 内部的 try/catch 捕获了异常，异常可以在 Fiber 内消化；只有未处理时才会从外部的 throw() 调用处继续冒泡。

超时应该用 resume 传标记还是 throw？

如果超时代表当前任务失败或需要清理，优先使用 throw()；普通业务事件才使用 resume() 传值。这样异常路径和成功路径不会混在一个字符串协议里。