À propos de la programmation multi-processus PHP (explication détaillée du code)

programmation multi-processus PHP

La prise en charge du contrôle de processus PHP implémente la création de processus et l'exécution de programmes de style Unix, Signal manipulation et interruption du processus. Le contrôle de processus ne peut pas être utilisé dans un environnement de serveur Web et peut entraîner des résultats inattendus lorsqu'il est utilisé dans un environnement de service Web.

Fonction pcntl

pcntl_fork() : Génère une branche (processus enfant) à la position actuelle du processus actuel.

Annotation : fork crée un processus enfant.Le processus parent et le processus enfant continuent de s'exécuter à partir de la position fork. La différence est que pendant l'exécution du processus parent, la valeur de retour de fork est le processus enfant. nombre. Ce que le processus enfant obtient est 0

<?php
$pid = pcntl_fork();
//父进程和子进程都会执行下面代码
if ($pid == -1) {
    //错误处理：创建子进程失败时返回-1.
     die(&#39;could not fork&#39;);
} else if ($pid) {
     //父进程会得到子进程号，所以这里是父进程执行的逻辑
     pcntl_wait($status); //等待子进程中断，防止子进程成为僵尸进程。
} else {
     //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。
    exit();//子进程执行完后应该退出，不然会继续执行后面的逻辑
}

● pcntl_wait(int &$status[, int $options = 0]) : Attend ou renvoie l'état du processus enfant de fork, équivalent à pcntl_waitpid(-1). ,int &$ status[,int $options = 0])

greep pcntl_waitpid(int $pid, int &$status[,int $options = 0]) $status est le paramètre de la fonction suivante

● pcntl_wifexited(int $status) vérifie si le code d'état du processus enfant représente une sortie normale,

● pcntl_wexistatus(int $status) renvoie un code retour de processus enfant interrompu, valable uniquement pour une interruption normale

Quantity pcntl_wifsignaled(int $status) vérifie si le processus enfant s'est terminé par un signal non intercepté. Renvoie vrai si oui, faux sinon

Quantity pcntl_wtermsig(int $status) renvoie le signal qui a provoqué l'interruption du processus enfant. Il est valide lorsque pcntl_wifsignaled renvoie true

<?php
 echo "主进程\n";
 $pid = pcntl_fork();
 //父进程和子进程都会执行这些代码
 if($pid == -1 ){
     //创建子进程失败会返回-1
     throw new Exception (&#39;fork error on Task object&#39;);
 }else if($pid){
     //创建成功会父进程会得到子进程的pid
     echo "等待子进程执行";
     pcntl_wait($status);//等待子进程中断
     echo "子进程执行状态：";
     echo "是否正常退出：",pcntl_wifexited($status),"\n";
     echo "子进程返回的代码：",pcntl_wexitstatus($status),"\n";//仅在pcntl_wifexited返回true时生效,只能是int，输出123
     echo "子进程是否是由于某个未捕获的信号退出的：",pcntl_wifsignaled($status),"\n";//如果是kill -9|-15 杀死的进程返回true
     echo "导致子进程中断的信号：",pcntl_wtermsig($status),"\n"; 输出 9 | 15
     var_dump($status);
 }else{
     //创建成功子进程会得到pid=0
     sleep(2);
     echo "子进程执行完毕\n";
         exit(123)
 }

weight pcntl_alarm(. int $seconds) : est Le processus définit un signal d'alarme

● pcntl_signal(int $signo, callback $handler [, bool $restart_syscalls = true ]) Installe un nouveau gestionnaire de signal pour le signal spécifié

weight pcntl_signal_get_handler (int $signo) Récupère la fonction de traitement du signal spécifié

<?php
 
echo "设置3秒之后发送闹钟信号\n";
pcntl_alarm(3);
 
function dealSigalarm(){
    echo "收到信号 SIGALRM \n退出程序。。。\n";
    exit();
}
 
echo "安装信号处理器\n";
pcntl_signal(SIGALRM,"dealSigalarm");//对于不能被阻塞、处理和忽略的信号，php为这些时间注册信号处理函数会产生一个致命错误SIGSTOP,SIGKILL
var_dump(pcntl_signal_get_handler(SIGUSR1));//输出dealSigalarm
pcntl_signal(SIGUSR1,function(){
    echo "收到用户自定义信号\n";
});
$i = 1;
while(1){
    sleep(1);
    echo $i++,"\n";
    echo "分发... \n";
    pcntl_signal_dispatch();
};

greep pcntl_getpriority( int $pid = getmypid() [, int $process_identifier = PRIO_PROCESS ]) Récupère la priorité du processus

Quantity pcntl_setpriority (int $priority [, int $pid = getmypid() [, int $process_identifier = PRIO_PROCESS]]) Définir la priorité du processus

Quantity getmypid() Récupérer le pid du processus php actuel

● posix_getpid() obtient le pid du processus actuel

<?php
 /**
 * php进程的优先级
 */
 
 for($i = 1;$i<=5;$i++){
     $pid = pcntl_fork();
     if($pid == -1){
         throw new Exception("fork error on task object");
     }else if ($pid){
         pcntl_wait($status);
     }else{
         $end_time = time()+3;
         $k = 0;
         while(time()<=$end_time){
             $k++;
         }
         $pid = getmypid();
         echo "当前进程id:".$pid,"优先级:",pcntl_getpriority($pid);
         pcntl_setpriority($i);
         echo "修改之后的优先级为：",pcntl_getpriority(),"\n";
         echo "执行了进程{$i} {$k}次\r\n";
         exit();
     }
 }

Pour plus de connaissances sur PHP, veuillez visiter le tutoriel php !

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!