在 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 多进程处理任务的方法,具体使用哪种方法取决于你的需求和代码实现的复杂度。