当前位置:首页 > PHP教程 > php高级应用 > 列表

关于php多进程编程(代码详解)

发布:smiling 来源: PHP粉丝网  添加日期:2022-05-31 11:32:04 浏览: 评论:0 

php多进程编程

PHP的进程控制支持实现了Unix方式的进程创建, 程序执行, 信号处理以及进程的中断。 进程控制不能被应用在Web服务器环境,当其被用于Web服务环境时可能会带来意外的结果。

pcntl函数

pcntl_fork():在当前进程当前位置产生分支(子进程)。

译注:fork是创建了一个子进程,父进程和子进程 都从fork的位置开始向下继续执行,不同的是父进程执行过程中,得到的fork返回值为子进程 号,而子进程得到的是0

  1. <?php 
  2.  
  3. $pid = pcntl_fork(); 
  4.  
  5. //父进程和子进程都会执行下面代码 
  6.  
  7. if ($pid == -1) { 
  8.  
  9.     //错误处理:创建子进程失败时返回-1. 
  10.  
  11.      die('could not fork'); 
  12.  
  13. else if ($pid) { 
  14.  
  15.      //父进程会得到子进程号,所以这里是父进程执行的逻辑 
  16.  
  17.      pcntl_wait($status); //等待子进程中断,防止子进程成为僵尸进程。 
  18.  
  19. else { 
  20.  
  21.      //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。 
  22.  
  23.     exit();//子进程执行完后应该退出,不然会继续执行后面的逻辑 
  24.  

● pcntl_wait(int &$status[, int $options = 0]):等待或返回fork的子进程状态,相当于pcntl_waitpid(-1,int &$status[,int $options = 0])

● pcntl_waitpid(int $pid , int &$status[,int $options = 0]) $status是作为一下函数的参数

● pcntl_wifexited(int $status) 检查子进程状态代码是否代表正常退出,

● pcntl_wexistatus(int $status) 返回一个中断的子进程返回代码,仅在正常中断才有效

● pcntl_wifsignaled(int $status) 检查子进程是否由某个未捕获的信号退出的。是返回true,否返回false

● pcntl_wtermsig(int $status)返回导致子进程中断的信号,当pcntl_wifsignaled返回true时有效

  1. <?php 
  2.  
  3.  echo "主进程\n"
  4.  
  5.  $pid = pcntl_fork(); 
  6.  
  7.  //父进程和子进程都会执行这些代码 
  8.  
  9.  if($pid == -1 ){ 
  10.  
  11.      //创建子进程失败会返回-1 
  12.  
  13.      throw new Exception ('fork error on Task object'); 
  14.  
  15.  }else if($pid){ 
  16.  
  17.      //创建成功会父进程会得到子进程的pid 
  18.  
  19.      echo "等待子进程执行"
  20.  
  21.      pcntl_wait($status);//等待子进程中断 
  22.  
  23.      echo "子进程执行状态:"
  24.  
  25.      echo "是否正常退出:",pcntl_wifexited($status),"\n"
  26.  
  27.      echo "子进程返回的代码:",pcntl_wexitstatus($status),"\n";//仅在pcntl_wifexited返回true时生效,只能是int,输出123 
  28.  
  29.      echo "子进程是否是由于某个未捕获的信号退出的:",pcntl_wifsignaled($status),"\n";//如果是kill -9|-15 杀死的进程返回true 
  30.  
  31.      echo "导致子进程中断的信号:",pcntl_wtermsig($status),"\n"; 输出 9 | 15 
  32.  
  33.      var_dump($status); 
  34.  
  35.  }else
  36.  
  37.      //创建成功子进程会得到pid=0 
  38.  
  39.      sleep(2); 
  40.  
  41.      echo "子进程执行完毕\n"
  42.  
  43.          exit(123) 
  44.  
  45.  } 

● pcntl_alarm(int $seconds):为进程设置一个alarn闹钟信号

● pcntl_signal(int $signo, callback $handler [, bool $restart_syscalls = true ] )为指定的信号安装一个新的信号处理器

● pcntl_signal_get_handler(int $signo) 获取指定信号的处理函数

  1. <?php 
  2.  
  3.    
  4.  
  5. echo "设置3秒之后发送闹钟信号\n"
  6.  
  7. pcntl_alarm(3); 
  8.  
  9.    
  10.  
  11. function dealSigalarm(){ 
  12.  
  13.     echo "收到信号 SIGALRM \n退出程序。。。\n"
  14.  
  15.     exit(); 
  16.  
  17.  
  18.    
  19.  
  20. echo "安装信号处理器\n"
  21.  
  22. pcntl_signal(SIGALRM,"dealSigalarm");//对于不能被阻塞、处理和忽略的信号,php为这些时间注册信号处理函数会产生一个致命错误SIGSTOP,SIGKILL 
  23.  
  24. var_dump(pcntl_signal_get_handler(SIGUSR1));//输出dealSigalarm 
  25.  
  26. pcntl_signal(SIGUSR1,function(){ 
  27.  
  28.     echo "收到用户自定义信号\n"
  29.  
  30. }); 
  31.  
  32. $i = 1; 
  33.  
  34. while(1){ 
  35.  
  36.     sleep(1); 
  37.  
  38.     echo $i++,"\n"
  39.  
  40.     echo "分发... \n"
  41.  
  42.     pcntl_signal_dispatch(); 
  43.  
  44. }; 

● pcntl_getpriority( int $pid = getmypid() [, int $process_identifier = PRIO_PROCESS ])获取进程的优先级

● pcntl_setpriority( int $priority [ , int $pid = getmypid() [, int $process_identifier = PRIO_PROCESS]])设置进程的优先级

● getmypid() 获取当前php进程的pid

● posix_getpid() 获取当前进程的pid

  1. <?php 
  2.  
  3.  /** 
  4.  
  5.  * php进程的优先级 
  6.  
  7.  */ 
  8.  
  9.    
  10.  
  11.  for($i = 1;$i<=5;$i++){ 
  12.  
  13.      $pid = pcntl_fork(); 
  14.  
  15.      if($pid == -1){ 
  16.  
  17.          throw new Exception("fork error on task object"); 
  18.  
  19.      }else if ($pid){ 
  20.  
  21.          pcntl_wait($status); 
  22.  
  23.      }else
  24.  
  25.          $end_time = time()+3; 
  26.  
  27.          $k = 0; 
  28.  
  29.          while(time()<=$end_time){ 
  30.  
  31.              $k++; 
  32.  
  33.          } 
  34.  
  35.          $pid = getmypid(); 
  36.  
  37.          echo "当前进程id:".$pid,"优先级:",pcntl_getpriority($pid); 
  38.  
  39.          pcntl_setpriority($i); 
  40.  
  41.          echo "修改之后的优先级为:",pcntl_getpriority(),"\n"
  42.  
  43.          echo "执行了进程{$i} {$k}次\r\n"
  44.  
  45.          exit(); 
  46.  
  47.      } 
  48.  
  49.  }

Tags: php多进程编程

分享到: