PHP Fiber 怎样把异步任务包装成同步接口

PHP Fiber 适合把“可暂停的异步任务”藏在一个普通方法后面：调用方只看到 SyncBridge::run() 返回结果，调度器则在 Fiber 挂起期间处理 I/O，完成后再恢复它。要先划清边界：Fiber 是协作式调用栈，不会自动创建线程，也不会把同步阻塞的网络请求变成异步请求。

官方地址：https://www.php.net/manual/en/language.fibers.php

最稳妥的做法是把 Fiber 当作“同步外观和异步调度器之间的桥”，让异步适配器负责真正的 I/O，让包装器只负责启动、挂起、恢复和传递异常。

先把 Fiber 的职责说清楚

PHP 8.1 引入 Fiber。它可以在调用栈的深层位置通过 Fiber::suspend() 挂起，外部再用 resume() 继续，或者用 throw() 把异常注入回去。这个特性让上层业务不必把每一层函数都改成回调，但异步 I/O 仍然需要事件循环、Promise 或客户端适配器配合。

定义一个能交还控制权的等待点

下面的 Await::value() 不负责发请求，它只把“等待哪个任务”交给当前 Fiber。外部调度器拿到 token 后，等底层异步客户端完成，再调用 resume()；失败时调用 throw()。

这里的 token 可以是请求 ID、队列任务 ID 或客户端自己的句柄。关键是它必须能被外部调度器映射到一次结果；不要把数据库查询、sleep() 或同步 HTTP 调用直接塞进等待点，否则 Fiber 仍会被阻塞。

用同步包装器收回普通返回值

包装器的职责是启动 Fiber，并把暂停事件交给注入的调度函数。这个示例用 $dispatch 模拟事件循环：成功时调用第二个参数 $resume，失败时调用第三个参数 $fail。真实项目应把它接到异步 HTTP、消息队列或数据库客户端的完成回调。

start();
        if ($fiber->isSuspended()) {
            $dispatch(
                $token,
                // 异步任务成功后恢复 Fiber，值会回到 suspend()。
                static function (mixed $value) use ($fiber): void {
                    $fiber->resume($value);
                },
                // 异步任务失败时把异常送回 Fiber。
                static function (Throwable $exception) use ($fiber): void {
                    $fiber->throw($exception);
                },
            );
        }

        // 调度器完成回调后，Fiber 已经终止或抛出异常。
        if ($fiber->isTerminated()) {
            $result = $fiber->getReturn();
        }
        return $result;
    }
}

// 业务层仍可按同步方式接收最终数据。
$profile = SyncBridge::run(
    static function (): array {
        $json = Await::value('profile:42');
        return json_decode($json, true, 512, JSON_THROW_ON_ERROR);
    },
    static function (string $token, callable $resume, callable $fail): void {
        // 这里应接入真正的异步客户端；示例直接交还一个结果。
        if ($token !== 'profile:42') {
            $fail(new RuntimeException('未知任务')); return;
        }
        $resume('{"id":42,"name":"Ada"}');
    },
);
?>

这个最小包装器适合说明调用关系，但生产实现还要考虑“调度回调尚未执行就返回”的情况。通常应由事件循环保证回调在当前桥接调用期间完成，或者让桥接器本身成为调度器的一部分；不能假定普通 PHP 请求会自动在后台继续执行。

把结果和异常都收回同步接口

resume() 传入的值会成为 Fiber::suspend() 的返回值，throw() 则会在挂起点抛出异常。业务层可以继续使用普通的 try/catch，但包装器要避免吞掉原始异常，也要检查 Fiber 的生命周期，防止重复启动或重复恢复。

getMessage());
    throw $e;
}
?>

发布前的边界清单

• PHP 版本至少为 8.1，并确认运行环境启用了项目需要的扩展。
• Fiber 只提供协作式切换；真正的并发等待必须来自非阻塞客户端或事件循环。
• 同一个 Fiber 不能重复 start()，已终止的 Fiber 不能再次 resume()。
• 给 token、超时、取消和异常建立明确映射，避免调度器把结果恢复到错误任务。
• 如果任务内部调用了阻塞 API，包装器只是改变了调用外观，不能改善该段 I/O 的等待时间。

相关问题

Fiber 能代替 PHP 的多线程吗？

不能。Fiber 在同一执行上下文里协作式挂起，不等于操作系统线程；它更适合组织异步控制流。

为什么 Fiber 挂起后请求仍然卡住？

通常是等待点之外仍有同步阻塞调用，或者没有真正运行事件循环来恢复 Fiber。先检查 I/O 客户端和恢复回调是否都支持非阻塞。