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

Swoole は、PHP 用の高性能ネットワーク通信フレームワークであり、高性能ネットワーク同時プログラミングの実現に役立ちます。最も重要な機能の 1 つは、マルチプロセスのサポートです。これにより、マルチプロセスを介して同時実行性の高いネットワーク プログラミングを実装できます。

この記事では、Swoole を使用してマルチプロセスの作成、通信、同期などを含むマルチプロセス同時プログラミングを実装する方法と、具体的なコード例を紹介します。

1. 複数のプロセスの作成
   Swoole では、swoole_process クラスを使用して子プロセスを作成できます。以下は簡単な例です:

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

$process->start();

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

この例では、swoole_process クラスのコンストラクターを使用してサブプロセスが作成され、サブプロセスのロジック コードはコールバック関数を通じて実装されます。 start() メソッドは子プロセスを開始し、親プロセスは子プロセスによって送信されたメッセージを read() メソッドを通じて受信します。

2. マルチプロセス通信
   Swooleでは、パイプ、メッセージキュー、共有メモリなど、さまざまな方法を利用して複数プロセス間の通信を行うことができます。より一般的に使用されるのはパイプライン方式です。以下は、通信にパイプを使用する例です。

$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(); // 等待子进程退出

この例では、swoole_process クラスのコンストラクターを呼び出し、パイプ通信モードが有効であることを示すブール型パラメーターを渡します。次に、親プロセスで write() メソッドを呼び出して子プロセスにメッセージを送信し、read() メソッドを通じて子プロセスからメッセージを受信します。子プロセスでは、write() メソッドを使用して親プロセスにメッセージを送信し、read() メソッドを使用して親プロセスからメッセージを受信します。

3. マルチプロセスの同期
   マルチプロセス プログラミングでは、同期の問題を考慮する必要があります。 Swoole は、複数のプロセス間の同期を実現するさまざまな方法を提供します。最も一般的に使用される方法は、セマフォとロックを使用することです。以下は、同期にロックを使用する例です。

$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();

この例では、swoole_lock クラスを使用してミューテックス ロックを作成し、2 つの子プロセスでそれぞれロックおよびロック解除します。親プロセスでは、wait() メソッドを呼び出して、2 つの子プロセスの実行が完了するのを待ちます。

4. 完全な例
   次は、Swoole を使用して複数の子プロセスの作成、パイプを介した通信、同期のためのセマフォの使用など、マルチプロセス同時プログラミングを実装する方法を示す完全な例です。 。

$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.
";

この例では、3 つのサブプロセスを作成します。各サブプロセスはランダムに数値を生成し、この数値の 2 乗を計算して返します。親プロセスは、すべての子プロセスから返された結果をループを通じて受信し、コンソールに出力します。最終的に、親プロセスはすべてのタスクが完了したことを示すメッセージを出力します。

概要
Swoole は、マルチプロセス プログラミングを適切にサポートする、強力で高性能なネットワーク通信フレームワークです。 Swoole をマルチプロセス プログラミングに使用する場合、プロセスの作成、通信、同期などのさまざまな問題を考慮する必要があります。この記事では、読者が Swoole のマルチプロセス プログラミング スキルをよりよく理解し、習得できるように、具体的なコード例を提供します。

以上がSwooleを使用してマルチプロセス同時プログラミングを実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。