在伺服器跑腳本時,避免不了一些耗時任務,使用多進程是不可或缺的。而在 PHP5.5 之後,PHP 開始加入了多進程元素,以滿足開發需求。
推薦課程:PHP教學。
php多重過程一般應用在php_cli命令列中執行php腳本,實現多進程需要開啟的擴充:pcntl、 posix(pcntl是process control進程管理的縮寫) 。 Windows 環境下不支援 PHP 的多進程編程,本文主要在 Linux 環境下開發測試
pcntl_fork — 在目前進程目前位置產生分支(子進程)。
一個fork子程序的基礎範例:
$pid = pcntl_fork(); //父进程和子进程都会执行下面代码 if ($pid == -1) { //错误处理:创建子进程失败时返回-1. die('could not fork'); } else if ($pid) { //父进程会得到子进程号,所以这里是父进程执行的逻辑 pcntl_wait($status); //等待子进程中断,防止子进程成为僵尸进程。 } else { //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。 }
如果一個任務被分解成多個行程執行,就會減少整體的耗時。
例如有一個比較大的資料檔案要處理,這個檔案由很多行組成。如果單一進程執行要處理的任務,量很大時要耗時比較久。這時可以考慮多進程。
來看一道面試題,有一個1000萬個元素的int數組,需要求和,平均分到4個進程處理,每個進程處理一部分,再將結果統計出來,代碼如下
<?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"; }
上訴答案中,是把陣列分成4個子數組分別用4個子進程去處理了,但是沒有辦法把所計算的結果相加,因為進程都是獨立完成任務的,沒有辦法共享同一個(記憶體)變量,下面將引進訊息佇列來解決進程通訊的問題
<?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
以上是php多進程函數是什麼的詳細內容。更多資訊請關注PHP中文網其他相關文章!