探索 PHP 中的并发性和并行性：实践教程和技巧

<?php// check if pcntl is availableif (!function_exists('pcntl_fork')) {    die('the pcntl extension is not available.');}$pid = pcntl_fork();if ($pid == -1) {    // fork failed    die('could not fork');} elseif ($pid) {    // parent process    echo "parent process";    pcntl_wait($status); // wait for child process to finish} else {    // child process    echo "child process";    sleep(2); // simulate a task    echo "child process finished";}?>

composer require react/event-loop

<?phprequire 'vendor/autoload.php';use reacteventloopactory;use reactpromisepromiseinterface;$loop = factory::create();// function to simulate an asynchronous taskfunction asynctask($name) {    return new promiseinterface(function ($resolve, $reject) use ($name) {        echo "starting $name...";        sleep(2); // simulate a delay        echo "$name completed.";        $resolve();    });}$promise1 = asynctask('task 1');$promise2 = asynctask('task 2');// wait for all promises to complete$loop->run();?>

<?php// check if parallel is availableif (!extension_loaded('parallel')) {    die('the parallel extension is not available.');}use parallel{runtime, future};// function to run in parallelfunction task($name) {    echo "task $name started";    sleep(2); // simulate a task    echo "task $name completed";}// create runtime environments$runtime1 = new runtime();$runtime2 = new runtime();// start tasks in parallel$future1 = $runtime1->run(function() {    task('1');});$future2 = $runtime2->run(function() {    task('2');});// wait for tasks to complete$future1->value();$future2->value();?>

<?php// Check if pthreads is availableif (!extension_loaded('pthreads')) {    die('The pthreads extension is not available.');}class Worker extends Thread {    private $name;    public function __construct($name) {        $this->name = $name;    }    public function run() {        echo "Thread {$this->name} started";        sleep(2); // Simulate a task        echo "Thread {$this->name} completed";    }}$worker1 = new Worker('1');$worker2 = new Worker('2');// Start threads$worker1->start();$worker2->start();// Join threads to main script$worker1->join();$worker2->join();?>