php如何使用多進程

這篇文章給大家分享的是有關(guān)php如何使用多進程的內(nèi)容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

1. 代碼：

   <?php
   /**
   * @desc：多進程處理任務(wù)類
   * @author [Lee] <[<complet@163.com>]>
   */
   class process{
   public $num = 10;  #  進程數(shù)
   public $timeout = 4;  #  延遲時間
   public $pipedir = "pipe/";  #  管道目錄
   public $logdir = "log/";  #  日志目錄
   public $errlog = "err.log";  #  錯誤日志
   public $successlog = "success.log";  #  成功日志
   /*
    @desc：構(gòu)造方法，創(chuàng)建相關(guān)目錄，檢察是否支持擴展
    */
   public function __construct(){
       $pipedir = $this->pipedir;
       $logdir = $this->logdir;
       if(!is_dir($pipedir)){
           if(!mkdir($pipedir)){
               $this->write_log(1,"創(chuàng)建管道目錄{$pipedir}失敗");
           }
       }
       if(!is_dir($logdir)){
           if(!mkdir($logdir)){
               $this->write_log(1,"創(chuàng)建日志目錄{$logdir}失敗");
           }
       }
       if (!function_exists('pcntl_fork')) {
           $this->write_log(1,'未安裝pcntl擴展');
           exit;
       }
   }
   /*
    @desc：內(nèi)部方法，寫日志
    @param type 日志類型 1錯誤日志 2成功日志
    @param msg 日志消息 
    */
   private function write_log($type,$msg){
       $logdir = $this->logdir;
       $errlog = $this->errlog;
       $successlog = $this->successlog;
       $prelog = date('Y-m-d H:i:s')."：";
       if($type == 1){
           $logname = $logdir.$errlog;
       }else{
           $logname = $logdir.$successlog;
       }
       file_put_contents($logname,$prelog.$msg.PHP_EOL,FILE_APPEND);
   }
   /*
    @desc：主方法，執(zhí)行程序
    @param name 執(zhí)行命令的回調(diào)函數(shù)
    */
   public function run($name){
       $num = $this->num;
       $timeout = $this->timeout;
       $pipedir = $this->pipedir;
       $pipefile = $pipedir.posix_getpid();
       if (!posix_mkfifo($pipefile, 0666)) {
           $this->write_log(1,"創(chuàng)建管道文件{$pipefile}失敗");
           exit;
       }
       #  處理任務(wù)
       for ($i = 0; $i < $num; ++$i ) {
           $cpid = pcntl_fork();  #  創(chuàng)建子進程
           if ($cpid == 0) {
               #  子進程過程
               call_user_func($name,$i);
               $pw = fopen($pipefile, 'w');
               fwrite($pw, $i."\n");  #  當前任務(wù)處理完比，在管道中寫入數(shù)據(jù)
               fclose($pw);
               exit(0);  #  執(zhí)行完后退出
           }
       }
       #  父進程
       $pr = fopen($pipefile, 'r');
       stream_set_blocking($pr, FALSE);  #  將管道設(shè)置為非堵塞，用于適應(yīng)超時機制
       $pdata = '';  #  存放管道中的數(shù)據(jù)
       $sline = 0;  #  成功執(zhí)行的進程數(shù)量
       $stime = time();
       while ($sline < $num && (time() - $stime) < $timeout) {
           $tline = fread($pr, 1024);
           if (empty($tline)) {
               continue;   
           }
           #  用于分析多少任務(wù)處理完畢，通過'\n'標識
           foreach(str_split($tline) as $v) {
               if ("\n" == $v) {
                   ++$sline;
               }
           }
           $pdata .= $tline;
       }
       $this->write_log(2,"總共{$sline}個任務(wù)執(zhí)行成功");
       fclose($pr);
       unlink($pipefile);  #  刪除管道，已經(jīng)沒有作用了
       #  等待子進程執(zhí)行完畢，避免僵尸進程
       $n = 0;
       while ($n < $num) {
           $status = -1;
           $cpid = pcntl_wait($status, WNOHANG);
           if ($cpid > 0) {
               $this->write_log(2,"進程{$cpid}執(zhí)行結(jié)束");
               ++$n;
           }
       }
       #  驗證結(jié)果，主要查看結(jié)果中是否每個任務(wù)都完成了
       $arr = array();
       foreach(explode("\n", $pdata) as $i) {
           if (is_numeric(trim($i))) {
               array_push($arr, $i);  
           }
       }
       $arr = array_unique($arr);
       if ( count($arr) == $num) {  
           $this->write_log(2,var_export($arr,true));
       } else {
           $this->write_log(1,"執(zhí)行成功數(shù)量：".count($arr));
           $this->write_log(1,"執(zhí)行成功的線程：".var_export($arr,true));
       }
   }
   }

2. 測試：

   $process = new process();
   $process->num = 5;  #  修改進程數(shù)為5
   $process->run('todo');
   /*
   @desc：真實處理業(yè)務(wù)的方法
   @param pid 進程id
   */
   function todo($pid){
   $num = 19;  #  總?cè)蝿?wù)數(shù)
   $anum = ceil($num/5);  #  平均每個進程處理任務(wù)數(shù)
   $lnum = $num - $anum*(5-1);  #  最后一個進程處理任務(wù)數(shù)
   $minnum = $anum*$pid;  #  當前進程處理的最小值
   $maxnum;  #  當前進程處理的最大值
   if($pid<(5-1)){
       $maxnum = $minnum + $anum;
   }else{
       $maxnum = $num;
   }
   for($i=$minnum;$i<$maxnum;$i++){
       echo "進程號：{$pid}；輸出：{$i}".PHP_EOL;
   }
   }

3. 輸出：

   進程號：1；輸出：4
   進程號：1；輸出：5
   進程號：1；輸出：6
   進程號：1；輸出：7
   進程號：2；輸出：8
   進程號：2；輸出：9
   進程號：2；輸出：10
   進程號：2；輸出：11
   進程號：3；輸出：12
   進程號：3；輸出：13
   進程號：3；輸出：14
   進程號：3；輸出：15
   進程號：4；輸出：16
   進程號：4；輸出：17
   進程號：4；輸出：18
   進程號：0；輸出：0
   進程號：0；輸出：1
   進程號：0；輸出：2
   進程號：0；輸出：3

感謝各位的閱讀！關(guān)于“php如何使用多進程”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！