PHP中封装性的并发编程技术

<?php

$workers = [];
$workerNum = 5;

for ($i = 0; $i < $workerNum; $i++) {
    $pid = pcntl_fork();
    
    if ($pid == -1) {
        die("Fork failed");
    } else if ($pid == 0) {
        // worker process
        // do some work

        exit();
    } else {
        // parent process
        $workers[] = $pid;
    }
}

foreach ($workers as $pid) {
    pcntl_waitpid($pid);
}

?>

<?php

class MyThread extends Thread {
    public function run() {
        // do some work
    }
}

$threads = [];
$threadNum = 5;

for ($i = 0; $i < $threadNum; $i++) {
    $thread = new MyThread();
    $thread->start();

    $threads[] = $thread;
}

foreach ($threads as $thread) {
    $thread->join();
}

?>

<?php

$coroutine = new Coroutine();

for($i = 0; $i < 5; $i++) {
    $coroutine->create(function() {
        // do some work
    });
}

?>