PHP Fiber 怎样把协作式任务接入事件循环

PHP Fiber 接入事件循环，需要把“等待某个事件”封装成可挂起的函数：注册完成回调，再挂起当前执行上下文，由事件循环在条件满足后恢复它。Fiber 本身不提供定时器、网络事件或任务调度；下面以 Revolt 的 Suspension 为适配层，让业务代码保持顺序调用。

PHP 官方地址：https://www.php.net/
Revolt 官方地址：https://revolt.run/

先明确迁移到 Fiber 改变了什么

PHP Fiber 文档说明，这项能力自 PHP 8.1 引入，可在调用栈深处暂停，并在恢复时继续原来的函数。本文面向 CLI 协作任务，不把升级运行时等同于让现有 Web 请求自动并发。

在原生 API 中，Fiber::suspend()暂停当前 Fiber，Fiber::resume()传入的值成为该挂起点的返回值；异常也可被投递回挂起点。但使用事件循环库时，优先采用它的调度接口，不要自行恢复由库管理的 Fiber。Revolt 的Fiber 集成文档推荐使用 Suspension，并说明事件回调运行在 Fiber 中。

把等待点改为 Suspension 适配函数

先在自己的示例目录安装依赖，再将代码保存为 fiber-loop.php。Composer 会依据项目运行环境解析可用版本，应把锁文件纳入项目管理。

# 在示例项目中安装事件循环依赖；不修改 PHP 全局配置。
composer require revolt/event-loop

下面的 awaitDemoEvent()只模拟一个延迟完成事件，不发起 HTTP 或数据库请求。它为每次等待创建完成回调、超时回调和一个完成标记。完成标记在投递结果前设定，防止两个回调重复结束同一次等待。

resume('event-ready');
            }
        );

        // 超时事件：异常会在 suspend 的等待位置抛出。
        $callbackIds[] = EventLoop::delay(
            $timeout,
            static function () use (&$settled, $suspension): void {
                if ($settled) {
                    return;
                }
                $settled = true;
                $suspension->throw(new RuntimeException('等待超时'));
            }
        );

        return $suspension->suspend();
    } finally {
        // 无论成功还是超时，都注销仍未完成的定时回调。
        foreach ($callbackIds as $id) {
            EventLoop::cancel($id);
        }
    }
}

Revolt 定时器文档提供 delay()与回调标识；未到期的回调可用 cancel()注销。这里用两个定时器演示竞争结束条件，不能据此假定真实网络请求也具有相同的取消接口。

让多个任务共享同一个事件循环

把下面片段接在同一文件末尾。每个任务通过 defer()交给循环，并在自己的异常边界内调用等待函数。外层只启动一次循环，不在等待函数里嵌套创建另一套调度器。

// 任务 A、B 在超时前完成；C 的完成事件晚于自己的超时。
$jobs = [
    ['A', 0.02, 0.10],
    ['B', 0.04, 0.10],
    ['C', 0.20, 0.05],
];

foreach ($jobs as [$label, $readyAfter, $timeout]) {
    EventLoop::defer(
        static function () use ($label, $readyAfter, $timeout): void {
            try {
                $value = awaitDemoEvent($readyAfter, $timeout);
                echo $label . ': ' . $value . PHP_EOL;
            } catch (Throwable $error) {
                // 示例隔离每个任务的失败；生产环境应记录结构化错误。
                fwrite(STDERR, $label . ': ' . $error->getMessage() . PHP_EOL);
            }
        }
    );
}

// CLI 入口统一驱动循环；没有剩余事件时可结束。
EventLoop::run();

# 在已安装依赖、支持 Fiber 的 PHP CLI 下启动这个示例。
php fiber-loop.php

这是读者可运行的示例，本文没有执行，也没有附上实测输出。按参数设计，A、B 应走成功分支，C 应走超时分支；实际时间可能受其他回调和系统调度影响，不应将小数秒参数解释成精确完成时刻。

调度基础文档强调应用共享一个调度器。可挂起函数让调用方写得像顺序代码，但不会改变事件驱动的底层约束。

迁移真实 I/O 时保留清理和错误语义

实际接入时，将模拟完成定时器替换为相应客户端的完成通知。若使用底层流接口，先配置非阻塞模式，再注册可读或可写事件。Revolt 流文档指出，可读通知既可能代表数据可读，也可能代表 EOF；高层业务通常更适合使用成熟的流或协议客户端。

一次“可读”不等于已收到完整响应。需要由协议层累积数据、判断消息完整性，最终才恢复等待者。超时时除了停止等待，还要按客户端语义取消请求或关闭资源；注销一个事件回调，不一定能撤销已发送到远端的操作。

完成回调、超时回调都与同一 Suspension 关联，回调标识由资源清理逻辑持有。资源清理必须覆盖成功、超时、连接关闭及业务异常。如果加入主动取消，应让取消也通过同一个结束标记竞争，防止任务已离开等待点后又收到迟到恢复。

迁移时可以逐项保留以下检查条件：

• 同一任务的成功、失败和超时只能结束一次等待。
• 完成后不遗留未注销的监听器或定时器。
• 任务异常有调用方接收，不悄悄丢失。
• 等待期间允许其他任务取得进展。
• 底层 API 支持非阻塞行为，没有长时间占住线程的调用。

把 sleep 或同步 PDO 查询放进 Fiber 会自动异步吗？

不会。Fiber 只有在协作挂起点交还控制权，普通阻塞调用仍会占用执行线程。迁移需要替换等待适配层和相应客户端，不能只把原函数包进 Fiber。

可以在每个工具函数里调用 EventLoop::run() 吗？

示例采用统一 CLI 入口驱动循环。已有框架管理循环时，应接入其任务接口，避免工具函数争夺调度权；Revolt 的 Suspension 也支持在主上下文等待，但这不等于需要到处嵌套启动循环。

Fiber 适合加速长时间计算吗？

协作式并发不提供 CPU 并行。长计算若不交还控制权，会延后定时器和其他事件；需要并行时应另行考虑进程或合适的工作执行机制。