如何用PHP 8.1的Fiber替代pcntl_fork实现循环并行处理数据？

首先得明确：pcntl_fork是创建多进程实现真正的并行（能利用CPU多核），而PHP Fiber是单线程内的协程，属于协作式并发——只有当协程主动让出控制权时，才会切换到其他协程。如果你的get_data_function()是CPU密集型任务，Fiber替代不了多进程的性能；如果是IO密集型（比如网络请求、文件读写），Fiber可以提升单线程的利用率。

以下是适配Fiber的实现方案，核心是需要一个简单的协程调度器，以及让阻塞操作主动让出控制权：

完整实现代码 #

<?php

// 简单的协程调度器，管理所有协程生命周期
class FiberScheduler
{
    private array $fibers = [];

    public function add(Fiber $fiber): void
    {
        $this->fibers[] = $fiber;
    }

    public function run(): void
    {
        while (!empty($this->fibers)) {
            $fibers = $this->fibers;
            $this->fibers = [];

            foreach ($fibers as $fiber) {
                if (!$fiber->isStarted()) {
                    $fiber->start();
                } elseif (!$fiber->isTerminated()) {
                    $fiber->resume();
                    $this->fibers[] = $fiber;
                }
            }
        }
    }
}

// 封装sleep操作，让协程主动让出控制权
function fiber_sleep(int $seconds): void
{
    $start = time();
    // 每次让出控制权后检查是否到时间，避免长时间阻塞线程
    while (time() - $start < $seconds) {
        Fiber::suspend();
    }
}

// 你的业务处理函数示例
function get_data_function(string $name): void
{
    echo "开始处理 $name\n";
    // 替换为实际业务逻辑，若有IO阻塞操作，需在等待点调用suspend让出控制权
    fiber_sleep(1);
    echo "完成处理 $name\n";
}

// 主执行逻辑
$names = ['A', 'B', 'C', 'D', 'E'];
$scheduler = new FiberScheduler();

foreach ($names as $name) {
    // 为每个任务创建独立协程
    $fiber = new Fiber(function () use ($name) {
        get_data_function($name);
    });
    $scheduler->add($fiber);
}

// 启动调度器，执行所有协程
$scheduler->run();

关键说明 #

• 调度器FiberScheduler负责循环调度未完成的协程，直到所有任务结束
• fiber_sleep替代原生sleep，通过Fiber::suspend()主动让出控制权，让其他协程有执行机会
• 若get_data_function()包含其他阻塞操作（如数据库查询、HTTP请求），需改为非阻塞模式或在等待阶段调用Fiber::suspend()，否则协程会一直占用线程无法切换

与原pcntl_fork代码的核心差异 #

1. 并行/并发：原代码是多进程并行，可利用多核CPU；Fiber是单线程并发，仅能使用单个CPU核心
2. 资源隔离：多进程有独立内存空间，协程共享同一内存，需注意全局变量污染问题
3. 调度方式：多进程由操作系统调度，协程是协作式调度，必须主动让出控制权才会切换

内容的提问来源于stack exchange，提问作者david david