PHP Fiber封装可暂停任务并传递异常的实现方式

PHP Fiber 适合把一段任务暂停在明确的检查点，等调用方准备好数据或调度信号后再继续。封装时最重要的不是把它包装成“异步线程”，而是把三条边界写清：start() 或 resume() 收到暂停值，resume($value) 把值送回 Fiber::suspend()，任务正常结束后再用 getReturn() 读取结果。调度器需要中止任务时，则对暂停中的 Fiber 调用 throw(Throwable)。

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

先划清 start、suspend、resume 和 getReturn 的值边界

可以把 Fiber 看成一个有独立调用栈的任务盒子。start() 第一次进入闭包；闭包执行到 Fiber::suspend($pauseValue) 时，暂停值返回给调用方。之后调用 resume($resumeValue)，这个恢复值会成为暂停点的返回值，闭包继续执行。闭包用 return 正常结束后，最终结果才由 getReturn() 读取。

用一个任务闭包封装可暂停执行体

包装器先隐藏原始 Fiber，再把“启动、恢复、读取结果”做成有状态的方法。这样业务代码不用到处判断 isSuspended()，也不会误把暂停值当成最终结果。

fiber = new Fiber($work);
    }

    public function start(mixed ...$args): mixed
    {
        // start 只能进入一次，参数交给任务闭包。
        return $this->fiber->start(...$args);
    }

    public function resume(mixed $value = null): mixed
    {
        $this->assertSuspended();
        // value 会成为 Fiber::suspend() 的返回值。
        return $this->fiber->resume($value);
    }

    public function abort(Throwable $exception): mixed
    {
        $this->assertSuspended();
        // 异常从当前暂停点进入任务，交给任务边界决定是否处理。
        return $this->fiber->throw($exception);
    }

    public function result(): mixed
    {
        if (!$this->fiber->isTerminated()) {
            throw new LogicException('任务尚未正常结束');
        }
        // getReturn 读取的是闭包 return，不是暂停值。
        return $this->fiber->getReturn();
    }

    private function assertSuspended(): void
    {
        if (!$this->fiber->isSuspended()) {
            throw new LogicException('任务当前不在暂停态');
        }
    }
}

这层封装保留了 PHP 原生的异常语义：如果任务还没有暂停，resume() 和 throw() 都不应被调用；如果任务已经抛出异常终止，getReturn() 也不能伪装成成功结果。

用 Fiber::throw 把调度器异常送回暂停点

异常注入不是在调用方“替 Fiber 抛异常”，而是让异常从 Fiber 内部当前的 Fiber::suspend() 位置恢复。任务闭包可以在这个位置用 try/catch 转成业务结果；如果不捕获，异常就继续离开任务边界，交给上层调度器处理。

 true, 'signal' => $signal];
    } catch (RuntimeException $exception) {
        // 只处理任务协议允许的异常，其它异常继续向外冒泡。
        return ['ok' => false, 'reason' => $exception->getMessage()];
    }
});

$task->start();
$task->abort(new RuntimeException('quota exceeded'));
$result = $task->result();

这里 abort() 的返回值不是业务结果，因为 Fiber 已经在闭包中执行了 return。真正的结果统一从 result() 读取。若把 RuntimeException 换成未被捕获的异常，任务会异常终止，此时应在调度器边界捕获，而不是继续调用 getReturn()。

用状态判断和统一包装器收口调用约束

实际调度时，建议只暴露三种状态：ready 表示尚未启动，suspended 表示可以恢复或中止，terminated 表示已经结束。不要用一次 resume() 的返回值判断任务是否完成，因为它可能只是下一个暂停值；应结合 isSuspended()、isTerminated() 和显式的结果方法判断。

另外，Fiber 不会把阻塞的文件、数据库或网络调用自动变成并发。只有任务主动让出控制权，外部调度器才有机会运行别的任务。资源清理应放在任务自己的 finally 中，取消路径也要明确关闭临时句柄、释放锁或标记重试。

边界清单：什么时候值得封装 Fiber

• 适合：已有可拆分检查点的协作式任务，需要把暂停、恢复和取消异常统一成一个接口。
• 不适合：期待抢占式调度、后台线程或阻塞调用自动并行的场景。
• 必须约定：谁能调用 resume()，哪些异常允许被 abort() 注入，以及任务结果和失败如何落库或重试。

相关问题

Fiber::suspend() 可以在普通函数里调用吗？

可以，只要调用链当前运行在 Fiber 内；它不要求暂停点直接写在最外层闭包中。

什么时候可以调用 getReturn()？

Fiber 已正常终止并且闭包通过 return 给出结果时调用；尚未结束或异常终止时会得到 FiberError。

throw() 和普通 catch 有什么关系？

throw() 把 Throwable 注入当前暂停点，任务内部的 try/catch 可以处理它；未处理的异常仍应由外层调度器捕获。

Fiber 自己会创建事件循环吗？

不会。Fiber 只提供可暂停的调用栈，何时恢复、如何等待 I/O 仍由应用的调度器或事件循环决定。