在 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);
}
// 創建進程池
$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 多進程處理任務的方法,具體使用哪種方法取決于你的需求和代碼實現的復雜度。