PHP Forking:当孩子变成僵尸时杀死它

Question

我有这段代码，它在我的各种php cli程序中完美地满足了我的需要。只是有时候孩子会变成僵尸。

我的问题是，在哪里放置代码来检查一个孩子是否跑了，比如说5分钟，如果它更长，那么就杀死它？

我知道posix_kill可以杀死它，也知道如何跟踪它。There are examples of taskmanagers here。

我不确定如何将这些新功能组合到代码中。每次我尝试的时候，我都会陷入一片混乱。也许某个了解forking的人可以修复我的代码？

忽略所有的error_logs -我喜欢看看它运行时发生了什么。

public function __construct($data) {        
    //Keep track of all of the children processes
    $this->children = Array();

    //Specify the maximum number of child processes to fork at any given time
    $this->max_children = 5;
}

private function process()
{
    foreach ($collection as $stuff) 
    {
        //FORK THE PROCESS  
        $pid = pcntl_fork();

        //Something went wrong
        if($pid == -1) 
        {
            error_log ("could not fork");
            die ();
        }

        //PARENT PROCESS
        if($pid) 
        {
            //error_log ("Parent: forked " . $pid);
            $this->children[] = $pid;
        }
        //CHILD PROCESS
        else 
        {
            // Do stuff here                                                

            exit(); //Exit the child thread so it doesn't continue to process the data
        }

        //COLLECT ALL OF THE CHILDREN AS THEY FINISH
        while( ($c = pcntl_wait($status, WNOHANG OR WUNTRACED) ) > 0)
        {
            //error_log ("Collected Child - " . $c);
            $this->remove_thread($this->children, $c);

            error_log ("children left: " . count($this->children));
        }

        //WAIT FOR A CHILD TO FINISH IF MAXIMUM PROCESSES IS EXCEEDED
        if(sizeof($this->children) > $this->max_children)
        {
            //error_log ("Maximum children exceeded.  Waiting...");
            if( ($c = pcntl_wait($status, WUNTRACED) ) > 0)
            {
                //error_log ("Waited for Child - " . $c);
                $this->remove_thread($this->children, $c);

                error_log ("children left: " . count($this->children));
            }
        }
    }   

    //COLLECT ALL OF THE CHILDREN PROCESSES BEFORE PROCEEDING
    while( ($c = pcntl_wait($status, WUNTRACED) ) > 0){
        //error_log ("Child Finished - " . $c);
        $this->remove_thread($this->children, $c);

        error_log ("children left: " . count($this->children));
    }           
}

    //Function to remove elements from an array
private function remove_thread(&$Array, $Element)
{
    for($i = 0; $i < sizeof($Array); $i++)
    {
        //Found the element to remove
        if($Array[$i] == $Element){
            unset($Array[$i]);
            $Array = array_values($Array);
            break;  
        }
    }
}   

Answer 1

首先：WNOHANG OR WUNTRACED等于(布尔值为true)，WNOHANG | WUNTRACED为int (3)，这会造成很大的差异，尽管这里不一定如此。

   //set maximum child time.
   $maxruntime = 300;

   //.....
   //..... skip a lot of code, prefer trigger_error($msg,E_USER_ERROR) above die($msg) though
   //.....

  //if we are the parent
  if($pid) 
  {
      //store the time it started
      $this->children[$pid] = time();
  }

   //.....
   //..... skip 
   //.....


   //COLLECT ALL OF THE CHILDREN AS THEY FINISH
   while(count($this->children) > 0){
       //copy array as we will unset $this->children items:
       $children = $this->children;
       foreach($children as $pid => $starttime){
           $check = pcnt_waitpid($pid, $status, WNOHANG | WUNTRACED);
           switch($check){
                case $pid:
                   //ended successfully
                   unset($this->children[$pid];
                   break;
                case 0:
                   //busy, with WNOHANG
                   if( ( $starttime + $maxruntime ) < time() || pcntl_wifstopped( $status ) ){
                       if(!posix_kill($pid,SIGKILL)){
                           trigger_error('Failed to kill '.$pid.': '.posix_strerror(posix_get_last_error()), E_USER_WARNING);
                       }
                       unset($this->children[$pid];
                   }
                   break;
                case -1:
                default:
                   trigger_error('Something went terribly wrong with process '.$pid, E_USER_WARNING);
                   // unclear how to proceed: you could try a posix_kill,
                   // simply unsetting it from $this->children[$pid]
                   // or dying here with fatal error. Most likely cause would be 
                   // $pid is not a child of this process.
                   break;

       }
       // if your processes are likely to take a long time, you might
       // want to increase the time in sleep
       sleep(1);
   }

Answer 2

以下是我摆脱僵尸进程的方法……孩子们甚至可以与stdin对话，他们的僵尸将在终止过程中被杀死(SIGCHLD)。不需要等待任何东西，完全异步。

<?php

    declare(ticks = 1); // cpu directive

    $max=10;
    $child=0;

    $children = array();

    function sig_handler($signo) { // we release zombie souls in here, optimal place - shot exactly after childs death.
        global $child,$children;
        switch ($signo) {
                case SIGCHLD:
                    $child -= 1;
                    foreach($children as $pid){
                        $res = pcntl_waitpid($pid,$status, WNOHANG | WUNTRACED);
                        if($res != 0) unset($children[$pid]);
                    }
        }
    }

    pcntl_signal(SIGCHLD, "sig_handler"); // register fork signal handler to count running children

    while (true){ // <main_loop> - could be whatever you want, for, while, foreach... etc.

            while ($child >= $max) {
                sleep(1);
            }

            $child++;

            $pid=pcntl_fork();

            if($pid == -1){

            }else if($pid){

                $children[$pid] = $pid; // register new born children

            }else{ // <fork>

                echo "HELLO DADDY! I'M ALIVE! I CAN DO WHATEVER YOU WANT, DAD.";

                sleep(1); // avoid segmentation fault, when fork ends before handling signals
                exit(0);

            } // </fork>

        // optional timer between child spawn, avoiding wakeup on SIGCHLD
        $timeLeft = 5; // 5 seconds
        while ($timeLeft > 0) {
            $timeLeft = sleep($timeLeft);
        }

    } // </main_loop>

    while($child != 0){
        sleep(1);
    }

    ?>

计时器必须以这种方式实现，因为SIGCHLD会在每个sleep()中唤醒。Creds to 获取有关这方面的信息以及如何避免这种情况的想法。