PHP マルチプロセスでタスク処理を行う方法

2年 ago
優斗, 朝陽
1 minute

PHP でマルチプロセス処理を行う方法は、一般的に以下のようなものがあります。

  1. PCNTL拡張を使用する：PCNTLとはPHPの拡張で、複数のプロセスに関する関数を提供する。以下に、複数プロセスによるタスク処理を実現するための手順を示す。
// 创建子进程
$childPids = [];
for ($i = 0; $i < $numProcesses; $i++) {
    $pid = pcntl_fork();
    if ($pid == -1) {
        die('Fork failed');
    } elseif ($pid == 0) {
        // 子进程执行的逻辑
        // 处理任务
        exit(0);
    } else {
        $childPids[] = $pid;
    }
}

// 等待子进程结束
foreach ($childPids as $pid) {
    pcntl_waitpid($pid, $status);
}
  1. プロセスプールの使用：複数のサブプロセスを管理するにはプロセスプールを使用できます。プロセスプールは固定数のプロセスからなるキューであり、タスクは空いているサブプロセスに割り当てられて実行されます。以下はプロセスプールの簡単な実装例です。
// 创建进程池
$poolSize = 5;
$pool = [];
for ($i = 0; $i < $poolSize; $i++) {
    $pid = pcntl_fork();
    if ($pid == -1) {
        die('Fork failed');
    } elseif ($pid == 0) {
        // 子进程执行的逻辑
        while (true) {
            // 接收任务并处理
            // 如果没有任务，则等待
        }
        exit(0);
    } else {
        $pool[$pid] = true;
    }
}

// 分配任务给子进程
foreach ($tasks as $task) {
    while (true) {
        $pid = pcntl_waitpid(-1, $status, WNOHANG);
        if ($pid > 0) {
            $pool[$pid] = true;
        }

        foreach ($pool as $pid => $busy) {
            if (!$busy) {
                // 将任务发送给空闲的子进程
                $pool[$pid] = false;
                // ...
                break;
            }
        }
    }
}

// 等待子进程结束
while (count($pool) > 0) {
    $pid = pcntl_waitpid(-1, $status);
    unset($pool[$pid]);
}

PHP でマルチプロセスに取り組む際によくある 2 つの方法は、要件とコード実装の複雑さによって選択されます。

bannerAds