Was ist die PHP-Multiprozessfunktion?

Beim Ausführen von Skripten auf dem Server lassen sich einige zeitaufwändige Aufgaben nicht vermeiden und die Verwendung mehrerer Prozesse ist unerlässlich. Nach PHP5.5 begann PHP, Multiprozesselemente hinzuzufügen, um den Entwicklungsanforderungen gerecht zu werden.

Empfohlener Kurs: PHP-Tutorial.

PHP-Multiprozess wird im Allgemeinen verwendet, um PHP-Skripte in der php_cli-Befehlszeile auszuführen, um Erweiterungen zu implementieren, die für Multiprozess aktiviert werden müssen: pcntl, posix (pcntl ist die Abkürzung für Prozesssteuerung (Prozessmanagement). Die Multiprozessprogrammierung von PHP wird in der Windows-Umgebung nicht unterstützt. Dieser Artikel wurde hauptsächlich in der Linux-Umgebung entwickelt und getestet.

pcntl_fork – generiert einen Zweig (untergeordneten Prozess) an der aktuellen Position des aktuellen Prozesses.
Grundlegendes Beispiel eines Fork-Unterprozesses:

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

Wenn eine Aufgabe zur Ausführung in mehrere Prozesse aufgeteilt wird, wird der Gesamtzeitaufwand reduziert.
Zum Beispiel muss eine relativ große Datendatei verarbeitet werden. Diese Datei besteht aus vielen Zeilen. Wenn ein einzelner Prozess die zu bearbeitenden Aufgaben ausführt, dauert dies bei großem Volumen sehr lange. Zu diesem Zeitpunkt können mehrere Prozesse berücksichtigt werden.

Sehen wir uns eine Interviewfrage an. Es gibt ein int-Array mit 10 Millionen Elementen, das zu gleichen Teilen in 4 Prozesse aufgeteilt werden muss, und dann werden die Ergebnisse gezählt Der Code lautet wie folgt:

  <?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";
  }

In der Einspruchsantwort wird das Array in 4 Unterarrays unterteilt und jeweils von 4 Unterprozessen verarbeitet. Es gibt jedoch keine Möglichkeit, die berechneten Ergebnisse hinzuzufügen, da die Prozesse das abschließen Aufgaben unabhängig voneinander und es gibt keine Möglichkeit, dieselbe A-(Speicher-)Variable gemeinsam zu nutzen. Nachfolgend wird die Nachrichtenwarteschlange vorgestellt, um das Problem der Prozesskommunikation zu lösen

  <?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

Das obige ist der detaillierte Inhalt vonWas ist die PHP-Multiprozessfunktion?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!