Qu'est-ce que la fonction multi-processus php ?

Lors de l'exécution de scripts sur le serveur, certaines tâches chronophages ne peuvent être évitées et l'utilisation de plusieurs processus est essentielle. Après PHP5.5, PHP a commencé à ajouter des éléments multi-processus pour répondre aux besoins de développement.

Cours recommandé : Tutoriel PHP.

le multi-processus php est généralement utilisé pour exécuter des scripts php dans la ligne de commande php_cli afin d'implémenter les extensions qui doivent être activées pour le multi-processus : pcntl, posix (pcntl est l'abréviation de process control process management) . La programmation multi-processus de PHP n'est pas prise en charge dans l'environnement Windows. Cet article est principalement développé et testé dans l'environnement Linux

pcntl_fork - génère une branche (processus enfant) à la position actuelle du processus en cours.
Exemple de base d'un sous-processus fork :

$pid = pcntl_fork();
//父进程和子进程都会执行下面代码
if ($pid == -1) {
        //错误处理：创建子进程失败时返回-1.
         die('could not fork');
} else if ($pid) {
         //父进程会得到子进程号，所以这里是父进程执行的逻辑
         pcntl_wait($status); //等待子进程中断，防止子进程成为僵尸进程。
} else {
         //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。
}

Si une tâche est décomposée en plusieurs processus pour son exécution, la durée globale sera réduite.
Par exemple, il existe un fichier de données relativement volumineux à traiter. Ce fichier se compose de plusieurs lignes. Si un seul processus exécute les tâches à traiter, cela prendra beaucoup de temps si le volume est important. À l’heure actuelle, plusieurs processus peuvent être envisagés.

Regardons une question d'entretien. Il y a un tableau int avec 10 millions d'éléments qui doivent être additionnés. Il est divisé également en 4 processus, chaque processus traite une partie, puis les résultats sont comptés. le code est le suivant

  <?php

  $arrint = [0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15];//假设很多
  $arrint = array_chunk($arrint,4,TRUE);
  for ($i = 0; $i < 4; $i++){
      	$pid = pcntl_fork();
  if ($pid == -1) {
     	die("could not fork");
  } elseif ($pid) {
      	echo $pid;
      	echo "I'm the Parent $i\n";
  } else {
       	// 子进程处理
      	// $content = file_get_contents("prefix_name0".$i);
     	$psum = array_sum($arrint[$i]);
      	echo $psum . "\n";分别输出子进程的部分求和数字，但是无法进行想加，因为进程互相独立
     	exit;// 一定要注意退出子进程,否则pcntl_fork() 会被子进程再fork,带来处理上的影响。
       	}
  }
          
  // 等待子进程执行结
  while (pcntl_waitpid(0, $status) != -1) {
      	$status = pcntl_wexitstatus($status);
      	echo "Child $status completed\n";
  }

Dans la réponse à l'appel, le tableau est divisé en 4 sous-tableaux et traité respectivement par 4 sous-processus. Cependant, il n'y a aucun moyen d'ajouter les résultats calculés car les processus complètent le. tâches indépendamment et il n'y a aucun moyen de partager la même variable A (mémoire), la file d'attente de messages sera introduite ci-dessous pour résoudre le problème de la communication des processus

  <?php
  $arrint = [0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15];//假设很多
  $arrint = array_chunk($arrint,4,TRUE);//把数组分为4个

  // 创建消息队列,以及定义消息类型(类似于数据库中的库)
  $id = ftok(__FILE__,'m');//生成文件key，唯一
  $msgQueue = msg_get_queue($id);
  const MSG_TYPE = 1;
  msg_send($msgQueue,MSG_TYPE,'0');//给消息队列一个默认值0，必须是字符串类型
  
  //fork出四个子进程
  for ($i = 0; $i < 4; $i++){
   		$pid = pcntl_fork();
      	if ($pid == -1) {
          	die("could not fork");
      	} elseif ($pid) {
         	echo $pid;
          	echo "I'm the Parent $i\n";
      	} else {
      		// 子进程处理逻辑，相互独立，解决办法，放到内存消息队列中
          	$part = array_sum($arrint[$i]);
          	implode_sum($part);//合成计算出的sum
          	exit;// 一定要注意退出子进程,否则pcntl_fork() 会被子进程再fork,带来处理上的影响。
    	}
  }
          
  function implode_sum($part){
     	global $msgQueue;
      	msg_receive($msgQueue,MSG_TYPE,$msgType,1024,$sum);//获取消息队列中的值，最后一个参数为队列中的值
      	$sum = intval($sum) + $part;
      	msg_send($msgQueue,MSG_TYPE,$sum);//发送每次计算的结果给消息队列
  }
      
  // 等待子进程执行结束
  while (pcntl_waitpid(0, $status) != -1) {
      	$status = pcntl_wexitstatus($status);
      	$pid = posix_getpid();
      	echo "Child $status completed\n";
  }
      
  //所有子进程结束后，再取出最后在队列中的值，就是int数组的和
  msg_receive($msgQueue,MSG_TYPE,$msgType,1024,$sum);
  echo $sum;//输出120

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!