登录
推荐 文章 Go 技术 课程 下载 专题 AI
首页 >  文章 >  php教程

PHP Fiber 怎样在挂起点恢复执行

来源:17golang原创

时间:2026-11-14 21:29:05 203浏览 收藏

很多人第一次看 PHP Fiber,会把 resume() 理解成“从头再跑一次”。实际情况更像是在同一条 Fiber 调用栈上把执行权交回来:Fiber::suspend($value) 把 $value 交给外部调用者,之后 resume($value) 传入的值又会从原来的 suspend() 位置返回。只要把这两个方向分开,Fiber 的恢复行为就不难读。

PHP 官方文档将 Fiber 定义为可中断的完整调用栈,Fiber 从 PHP 8.1 开始提供。下面用一个很小的协作式任务说明挂起、恢复和异常边界,不把它当作线程,也不依赖第三方事件循环。

记住一句话:suspend() 的参数给外部,resume() 的参数给回挂起点;Fiber 结束后再用 getReturn() 取最终返回值。

先看清挂起点两侧的返回值

启动 Fiber 时,start() 会执行回调,直到回调返回、抛出异常,或遇到第一次 Fiber::suspend()。遇到挂起点后,start() 的返回值就是 suspend 传出的值;外部再次调用 resume() 时,resume 的参数才成为 suspend 表达式的返回值。

PHP Fiber 构造器、start、suspend、resume 与挂起点返回值的静态调用结构说明图
图1:调用结构说明图,查看 start/resume 如何与同一个 suspend 挂起点交换值。

因此,下面的两个 echo 不在同一次调用里连续执行:

start();
echo "外部收到:{$signal}" . PHP_EOL;

// 只有 suspended 状态才能恢复;这里的字符串会回到 $reply
$fiber->resume('继续执行');

按这个关系理解,外部先拿到“等待调度器输入”,随后 Fiber 内部才拿到“继续执行”。resume() 没有重新创建回调,也没有把局部变量清空。

用一个小任务串起多次恢复

如果回调里有多个挂起点,每次恢复只会把执行权送回当前那个挂起点,直到遇到下一个挂起点或直接结束。可以把每次 suspend() 看成任务对调度器提出的一次交接。

start();
echo $message1 . PHP_EOL;

$message2 = $fiber->resume('alpha');
echo $message2 . PHP_EOL;

$fiber->resume('beta');
// Fiber 终止后,最终 return 由 getReturn() 读取
echo $fiber->getReturn() . PHP_EOL;

这里 start() 得到“第一次交接”,第一次 resume('alpha') 得到第二个 suspend 的值,第二次 resume('beta') 不再返回新的挂起信号,因为回调已经返回;最终结果要从 getReturn() 读取。

把异常和状态边界放进调度器

调度器不要只盯着一个布尔变量。isStarted()、isSuspended()、isRunning() 和 isTerminated() 解决的是不同问题:是否启动过、当前是否能被恢复、当前是否仍在运行,以及是否已经结束。

PHP Fiber 状态观察方法、resume、throw 与 FiberError 的静态边界说明图
图2:状态边界说明图,查看恢复入口与 FiberError 的关系。

resume() 只能对处于 suspended 状态的 Fiber 使用。若 Fiber 尚未启动、正在运行或已经终止,调用它可能得到 FiberError。需要把失败注入 Fiber 时,用 throw(),异常会从原来的 suspend() 位置抛出。

getMessage()}" . PHP_EOL;
    }
});

$fiber->start();
if ($fiber->isSuspended()) {
    // 只有确认挂起后才选择 resume 或 throw
    $fiber->throw(new RuntimeException('外部依赖不可用'));
}

echo $fiber->isTerminated() ? '任务已结束' : '任务仍在等待';

异常处理完成后,Fiber 是否终止取决于回调有没有继续抛出异常。生产调度器应把 resume、throw 放进统一的异常处理边界,不要在不知道状态时盲目调用。

整理成可复用的最小工作单元

把一个 Fiber 当成“可暂停的任务对象”时,调用顺序可以压缩成四个判断:先用 start() 建立执行,只有 isSuspended() 为真时才恢复或注入异常;任务终止后不要再次 resume,而是读取 getReturn();任务异常则在外部捕获并记录原因。

调用它解决的问题容易混淆的地方
start()首次进入回调返回的是第一次 suspend 的值
resume($value)从当前挂起点继续$value 会成为 suspend 的返回值
throw($exception)从挂起点注入失败异常在 suspend 位置抛出
getReturn()取得回调最终 returnFiber 必须已经终止

最后再回看标题问题:PHP Fiber 不是靠重复调用回调恢复,而是保留调用栈,在 Fiber::suspend() 的原位置等待下一次交接。外部传值用 resume(),外部传错用 throw(),回调正常结束后用 getReturn() 收尾。

相关问题

Fiber::suspend() 能在 Fiber 外部调用吗?

不能。官方文档说明,在 Fiber 外部调用会抛出 FiberError,因此它只能作为 Fiber 回调调用栈中的挂起点。

为什么 resume() 没有拿到最终返回值?

当本次恢复让回调直接结束时,Fiber 不会再产生新的 suspend 值;最终 return 应在 Fiber 终止后通过 getReturn() 读取。

Fiber::throw() 和普通的 try/catch 有什么关系?

throw() 把异常送回当前挂起点,Fiber 内部的 try/catch 可以像处理普通异常一样接住它;如果没有接住,异常会沿 Fiber 的调用边界向外传播。

声明:本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>