php – 后续的pcntl_signal信号没有启动处理程序

发布时间：2020-12-13 13:10:19 所属栏目：PHP教程来源：网络整理

导读：Lemme首先给出了我所拥有的代码的基本描述.我从一个主要的父进程开始(注意：为了简单起见,我没有显示所有函数.如果你需要我在任何时候进行扩展,请告诉我)： declare(ticks=1);pcntl_signal(SIGHUP,array('forker','restartSignalHandler'));if(forker_is_not

Lemme首先给出了我所拥有的代码的基本描述.我从一个主要的父进程开始(注意：为了简单起见,我没有显示所有函数.如果你需要我在任何时候进行扩展,请告诉我)：

declare(ticks=1);
pcntl_signal(SIGHUP,array('forker','restartSignalHandler'));
if(forker_is_not_running()){
    new Forker();
}
class Forker {
    private $active_forks = array();
    private $parent_pid = null;

    public function __construct(){
        $this->parent_pid = getmypid();
        $this->create_fork();
        $this->wait_for_active();
    }

    public function wait_for_active(){
        while(!empty($this->active_forks)){
            foreach($this->active_forks as $k=>$fork){
                if($this->fork_no_longer_running($fork)){
                    unset($this->active_forks[$k]);
                }
            }
        }
    }

    // Pseudo code
    public function fork_no_longer_running($pid){
        // return true if 'ps -elf | grep $pid' doesn't returns only the grep command
        // else return false (aka the fork is still running)
    }

    public function create_fork(){
        $pid = pcntl_fork();
        if($pid == -1){
            posix_kill($this->parent_pid,SIGTERM);
        } else if($pid){
            // add the pid to the current fork
            $this->active_forks[] = $pid;
        } else {
            // Run our process
            pcntl_exec('/usr/bin/php',array('/domain/dev/www/index.php','holder','process'));
            exit(0);
        }
    }

    public function restartSignalHandler(){
        $forks = $this->active_forks;
        foreach($forks as $pid){
            $this->create_fork();
            posix_kill($pid,SIGINT);
        }
    }
}

class holder {
    public function process(){
        $x = new Processor();
    }
}

class Processor {
    public function __construct(){
        pcntl_signal(SIGINT,array($this,"shutdownSignalHandler"));
    }
    public function shutdownSignalHandler(){
        echo "Shutting down";
        exit;
    }
}

以下是发生的事情：

>我开始编写脚本并正确获取进程(例如Parentpid：2,childpid：3)
>然后我发送父母一个SIGHUP信号,它正确杀死和
开始一个新的子进程(例如Parentpid：2,childpid：4)
>然后我向父母发送第二个SIGHUP信号并正确尝试并添加一个新的子进程,但它拒绝杀死第二个childpid. (例如,Parentpid：2,undyingchildpid：4,newchildpid：5)

Lemme知道是否需要更多细节/没有意义.我无法弄清楚为什么第一次它会正确地杀死孩子,但第二次它没有.

甚至WEIRDER部分是当我更改它以便我更改我的重新启动处理程序以便它继续尝试使用SIGINT杀死子项时,它每次都失败,但是当我发送一个SIGKILL命令它会杀死子进程：

if($time_passed > 60){
    posix_kill($pid,SIGKILL);
}

我需要孩子能够被SIGINT杀死才能正确处理它.我不想只是SIGKILL它.是否有任何理由为什么第二次围绕SIGINT不起作用,但SIGKILL会？

首先,你不需要分叉.你的代码在子代内部执行一个exec,你基本上只需运行exec而不分叉,操作系统会在孩子时产生你的命令.如果你想使用fork,只需在子文件中包含该文件而不是执行.

public function create_fork(){
    //no need to actually fork!
    pcntl_exec('/usr/bin/php','process'));
}

//if you want to fork,better do it like this : 


public function create_fork(){
    $pid = pcntl_fork();
    if($pid == -1){
        posix_kill($this->parent_pid,SIGTERM);
    } else if($pid){
        // add the pid to the current fork
        $this->active_forks[] = $pid;
    } else {
       // Run our process
       include '/domain/dev/www/index.php';
       SomeClass::someMethod();
       exit(0);
    }
}

此外,使用fork时,您需要waitpid为孩子们.因此,在您的代码中,您需要插入以下内容：

//somewhere in a loop : 
$pidOfExittedChild = pcntl_waitpid (-1,$status,WNOHANG);
if ($pidOfExittedChild) {
    //a child has exitted,check its $status and do something
}

查看更多信息：
http://php.net/manual/en/function.pcntl-waitpid.php

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!