PHP多线程实时输出实现技巧

$descriptors = [
    0 => ["pipe", "r"], // stdin
    1 => ["pipe", "w"], // stdout
    2 => ["pipe", "w"]  // stderr
];

$processes = [];
$scripts = ['task1.php', 'task2.php', 'task3.php'];

foreach ($scripts as $script) {
    $process = proc_open("php $script", $descriptors, $pipes);
    if (is_resource($process)) {
        $processes[] = ['resource' => $process, 'pipes' => $pipes];
    }
}

// 实时读取每个进程的输出
while (!empty($processes)) {
    foreach ($processes as $index => $item) {
        $pipe = $item['pipes'][1];
        if (feof($pipe)) {
            proc_close($item['resource']);
            unset($processes[$index]);
        } else {
            $output = fgets($pipe, 1024);
            if ($output) {
                echo "<div>[输出] $output</div>";
                flush(); ob_flush();
            }
        }
    }
    usleep(100000); // 避免CPU空转
}

@ini_set('zlib.output_compression', 'Off');
@ini_set('implicit_flush', 'On');
ob_implicit_flush(true);
for ($i = 0; $i < ob_get_level(); $i++) {
    ob_end_flush();
}

$workers = [];
for ($i = 0; $i < 3; $i++) {
    $process = new Swoole\Process(function () use ($i) {
        for ($j = 0; $j < 5; $j++) {
            echo "Worker $i: Step $j\n";
            sleep(1);
        }
    });
    $process->start();
    $workers[] = $process;
}

foreach ($workers as $worker) {
    Swoole\Process::wait();
}