Swooleを使用してマルチプロセス同時プログラミングを実装する方法

$process = new swoole_process(function(swoole_process $process) {
    // 子进程的逻辑代码
    $process->write("Hello world!
"); // 向主进程发送消息
    $process->exit();
});

$process->start();

// 父进程接收子进程消息
$msg = $process->read();
echo $msg;

$process = new swoole_process(function(swoole_process $process) {
    $process->write("Hello world!
");
    $data = $process->read();
    echo "Child process received: " . $data;
    $process->exit();
}, true); // 启用管道通信模式

$process->start();

$msg = $process->read();
echo $msg;
$process->write("I am the parent process.
");
$process->wait(); // 等待子进程退出

$lock = new swoole_lock(SWOOLE_MUTEX); // 创建一个互斥锁

$process1 = new swoole_process(function(swoole_process $process) use ($lock) {
    $lock->lock(); // 加锁
    echo "Process 1 acquired the lock.
";
    sleep(1);
    $lock->unlock(); // 解锁
});

$process2 = new swoole_process(function(swoole_process $process) use ($lock) {
    $lock->lock(); // 加锁
    echo "Process 2 acquired the lock.
";
    sleep(1);
    $lock->unlock(); // 解锁
});

$process1->start();
$process2->start();

$process1->wait();
$process2->wait();

$workers = [];
$worker_num = 3;

for ($i = 0; $i < $worker_num; $i++) {
    $process = new swoole_process(function (swoole_process $worker) {
        $num = rand(1, 100);
        echo "Worker {$worker->pid} is calculating the square of $num...
";
        sleep(1);
        $worker->write($num * $num);
        $worker->exit();
    }, true);

    $pid = $process->start();
    $workers[$pid] = $process;
}

// 父进程接收子进程返回的计算结果
foreach ($workers as $pid => $process) {
    $result = $process->read();
    echo "Worker $pid calculated the result: $result
";
}

echo "All workers have completed their tasks.
";