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

(*-*)浩
Libérer: 2023-04-06 16:40:01
original
3335 Les gens l'ont consulté

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.
Qu'est-ce que la fonction multi-processus 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, 所以这里是子进程执行的逻辑。
}
Copier après la connexion

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";
  }
Copier après la connexion

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
Copier après la connexion

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!

Étiquettes associées:
php
source:php.cn
Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Tutoriels populaires
Plus>
Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal