PHP 分叉和多个子信号

Question

我正在尝试编写一个脚本，使用 < 创建多个分叉子进程代码>pcntl_*函数。

基本上，有一个脚本循环运行大约一分钟，定期轮询数据库以查看是否有要运行的任务。如果有的话，它应该在一个单独的进程中分叉并运行该任务，以便父进程不会被长时间运行的任务所阻碍。

由于可能有大量任务可供运行，因此我想限制创建的子进程的数量。因此，我通过每次创建一个变量时递增一个变量（如果太多则暂停）来跟踪进程的数量，然后在信号处理程序中递减它。有点像这样：

define(ticks = 1);

$openProcesses = 0; // how many we have open
$max = 3;           // the most we want open at a time

pcntl_signal(SIGCHLD, "childFinished");

while (!time_is_up()) {
    if (there_is_something_to_do()) {
        $pid = pcntl_fork();
        if (!$pid) {      // I am the child
            foo();        //   run the long-running task
            exit(0);      //   and exit
        } else {          // I am the parent
            ++$openProcesses;
            if ($openProcesses >= $max) {
                pcntl_wait($status);    // wait for any child to exit 
            }                           // before continuing
        }
    } else {
        sleep(3);
    }
}

function childFinished($signo) {
    global $openProcesses;
    --$openProcesses;
}

在大多数情况下，这工作得很好，除了两个或多个进程同时完成时 - 信号处理函数仅被调用一次，这会抛出我的计数器。其原因由 PHP 手册的 注释中的“匿名”解释：

多个子进程返回的数量小于给定时刻退出的子进程的数量。对于 Unix (POSIX) 系统，SIGCHLD 信号是正常行为。 SIGCHLD 可能被解读为“一个或多个孩子改变了状态——去检查你的孩子并收获他们的状态值”。

我的问题是：如何检查子进程并获取他们的状态？有没有可靠的方法来检查在任何给定时间有多少子进程打开？

_{使用 PHP 5.2.9}

Answer 1

一种方法是保留子进程的 PID 数组，并在信号处理程序中检查每个 PID 以查看它是否仍在运行。 （未经测试的）代码如下所示：

declare(ticks = 1);

$openProcesses = 0; 
$procs = array();
$max = 3;

pcntl_signal(SIGCHLD, "childFinished");

while (!time_is_up()) {
    if (there_is_something_to_do()) {
        $pid = pcntl_fork();
        if (!$pid) {      
            foo();        
            exit(0);      
        } else {          

            $procs[] = $pid; // add the PID to the list

            ++$openProcesses;
            if ($openProcesses >= $max) {
                pcntl_wait($status);     
            }                           
        }
    } else {
        sleep(3);
    }
}

function childFinished($signo) {

    global $openProcesses, $procs;

    // Check each process to see if it's still running
    // If not, remove it and decrement the count
    foreach ($procs as $key => $pid) if (posix_getpgid($pid) === false) {
        unset($procs[$key]);
        $openProcesses--;
    }

}

Answer 2

您可以让子级在启动时向父级发送 SIGUSR1，然后在退出前向父级发送 SIGUSR2。使用原始信号时要处理的另一件事是内核合并它们，而 RT 信号则不会这样做。理论上，任何非 rt 信号都可以合并。

您可以使用 sqlite 实现某种简单的锁定，其中一次只有一个孩子可以拥有说话棒。只要确保孩子们正常处理致命信号，以便他们保持活动状态以释放锁即可。

Answer 3

我知道这已经晚了大约 8 年（我希望你找到答案），但为了防止它对其他人有帮助，我会回答。

pcntl_w* 函数的使用将成为您的朋友，您可能想要实现一个进程收割机。该文档不是很有帮助，并且仍然不包含任何有用的示例。

这将是一个由多个部分组成的过程：

1 - 使用 pcntl_signal 将捕获的信号发送到您的信号处理程序

2 - 在该循环内进行循环/轮询；

3 - 迭代您的子数组（您将在下面创建）并根据需要收割它们

4 - fork()：这将包括以下内容：

pcntl_async_signals(true);

$children = array();
while ($looping === true)
{
    reapChildren();
    if (($pid = pcntl_fork()) exit (1); // error
    elseif ($pid) // parent
    { 
        $children[] = $pid;
        // close files/sockets/etc
        posix_setpgid ($pid,posix_getpgrp());
    }
    else
    { // child
        posix_setpgid(posix_getpid(),posix_getppid());
        // ... jump to child function/object/code/etc ...
        exit (0); // or whatever code you want to return
    }
} // end of loop

在收割机中，您将需要以下内容：

function reapChildren()
{
    global $children;
    foreach ($children as $idx => $pid)
    {
        $rUsage = array();
        $status = 0; // integer which will be used as the $status pointer
        $ret = pcntl_waitpid($pid, $status, WNOHANG|WUNTRACED, $rUsage);
        if (pcntl_wifexited($status)) // the child exited normally
        {
            $exitCode = pcntl_wexitstatus($status); // returns the child exit status
        }
        if (pcntl_wifsignaled($status))  // the child received a signal
        {
            $signal = pcntl_wtermsig($status); // returns the signal that abended the child
        }
        if (pcntl_wifstopped($status))
        {
            $signal = pcntl_wstopsig($status); // returns the signal that  stopped the child
        }
    }
}

上面的收割机代码将允许您可以轮询您孩子的状态，如果您使用的是 php7+，则在信号处理程序中填写的 $signalInfo 数组将包含许多您可以使用的有用信息.. var_dump 它.. 检查一下。另外，在 php7+ 中使用 pcntl_async_signals(true) 取代了声明(ticks=1) 和手动调用 pcntl_signal_dispatch() 的需要；

我希望这有帮助。