php 的多進程操作實踐案例分析
本文實例講述了php 的多進程操作。分享給大家供大家參考,具體如下:
php的多進程處理依賴于pcntl擴展,通過pcntl_fork創建子進程來進行并行處理。
例1如下:
<?php$pid = pcntl_fork();if($pid == -1) { //錯誤處理:創建子進程失敗時返回-1. die(’fork error’);} else if ($pid) { //父進程會得到子進程號,所以這里是父進程執行的邏輯 echo 'parent n'; //等待子進程中斷,防止子進程成為僵尸進程。 pcntl_wait($status);} else { //子進程得到的$pid為0, 所以這里是子進程執行的邏輯。 echo 'child n'; exit;}
pcntl_fork創建了子進程,父進程和子進程都繼續向下執行,而不同是父進程會獲取子進程的$pid也就是$pid不為零。而子進程會獲取$pid為零。通過if else語句判斷$pid我們就可以在指定位置寫上不同的邏輯代碼。
上述代碼會分別輸出parent和child。那么輸出的parent和child是否會有順序之分?是父進程會先執行?
例2如下:
<?php$pid = pcntl_fork();if($pid == -1) { die(’fork error’);} else if ($pid) { sleep(3); echo 'parent n'; pcntl_wait($status);} else { echo 'child n'; exit;}
我們在父進程中通過sleep來延緩執行,看看效果。
結果是,很快輸出了child,等待了接近3秒后,才輸出parent。所以父進程和子進程的執行是相對獨立的,沒有先后之分。
那么問題又來了?pcntl_wait是做什么用的?會掛起當前進程,直到子進程退出,如果子進程在調用此函數之前就已退出,此函數會立刻返回。子進程使用的資源將被釋放。
例3如下:
<?php$pid = pcntl_fork();if($pid == -1) { die(’fork error’);} else if ($pid) { pcntl_wait ($status); echo 'parent n';} else { sleep(3); echo 'child n'; exit;}
上述代碼,我們可以看到,父進程執行pcntl_wait時就已經掛起,直到等待3秒后輸出child,子進程退出后。父進程繼續執行,輸出parent。
例4如下:
<?phpdefine(’FORK_NUMS’, 3);$pids = array();for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die(’fork error’); } else if ($pids[$i]) { pcntl_waitpid($pids[$i], $status); echo 'pernet n'; } else { sleep(3); echo 'child id:' . getmypid() . ' n'; exit; }}
上述代碼,我們創建3個子進程,父進程分別掛起等待子進程結束后,輸出parent。
輸出結果如下:
child id:19090pernetchild id:19091pernetchild id:19092pernet
例5如下:
<?phpdefine(’FORK_NUMS’, 3);$pids = array();for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die(’fork error’); } else if ($pids[$i]) { } else { sleep(3); echo 'child id:' . getmypid() . ' n'; exit; }}foreach($pids as $k => $v) { if($v) { pcntl_waitpid($v, $status); echo 'parent n'; }}
輸出結果如下:
child id:19118child id:19119child id:19120parentparentparent
為什么上述代碼跟例4的輸出結果不一樣?
我們可以看到例5的pcntl_waitpid函數放在了foreach中,foreach代碼是在主進程中,也就是父進程的代碼中。當執行foreach時,可能子進程已經全部執行完畢并退出。pcntl_waitpid會立刻返回,連續輸出三個parent。
(*在子進程中,需通過exit來退出,不然會產生遞歸多進程,父進程中不需要exit,不然會中斷多進程。)
例6如下:
<?phpdefine(’FORK_NUMS’, 3);$pids = array();$fp = fopen(’./test.log’, ’wb’);$num = 1;for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die(’fork error’); } else if ($pids[$i]) { } else { for($i = 0; $i < 5; ++$i) { flock($fp, LOCK_EX); fwrite($fp, getmypid() . ’ : ’ . date(’Y-m-d H:i:s’) . ' : {$num} rn'); flock($fp, LOCK_UN); echo getmypid(), ': success rn'; ++$num; } exit; }}foreach($pids as $k => $v) { if($v) { pcntl_waitpid($v, $status); }}fclose($fp);
代碼如上:我們創建三個子進程,來同時向test.log文件寫入內容,test.log內容如下:
19507 : 2016-03-16 20:40:52 : 119507 : 2016-03-16 20:40:52 : 219507 : 2016-03-16 20:40:52 : 319507 : 2016-03-16 20:40:52 : 419507 : 2016-03-16 20:40:52 : 519509 : 2016-03-16 20:40:52 : 119509 : 2016-03-16 20:40:52 : 219509 : 2016-03-16 20:40:52 : 319509 : 2016-03-16 20:40:52 : 419509 : 2016-03-16 20:40:52 : 519508 : 2016-03-16 20:40:52 : 119508 : 2016-03-16 20:40:52 : 219508 : 2016-03-16 20:40:52 : 319508 : 2016-03-16 20:40:52 : 419508 : 2016-03-16 20:40:52 : 5
我們可以看到三個子進程的pid,它們分別執行了5次,時間幾乎是在同時。但是$num的值并沒像我們期望的那樣從1-15進行遞增。子進程中的變量是各自獨立的,互不影響。子進程會自動復制父進程空間里的變量。
如何在進程中共享數據?
我們通過php的共享內存函數shmop來實現。
<?phpdefine(’FORK_NUMS’, 3);$pids = array();$fp = fopen(’./test.log’, ’wb’);$num = 1;//共享內存段的key$shmKey = 123;//創建共享內存段$shmId = shmop_open($shmKey, ’c’, 0777, 64);//寫入數據到共享內存段shmop_write($shmId, $num, 0);for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die(’fork error’); } else if ($pids[$i]) { //阻塞,等待子進程退出 //注意這里,如果是非阻塞的話,$num的計數會出現問題。 pcntl_waitpid($pids[$i], $status); } else { //讀取共享內存段中的數據 $num = shmop_read($shmId, 0, 64); for($i = 0; $i < 5; ++$i) { fwrite($fp, getmypid() . ’ : ’ . date(’Y-m-d H:i:s’) . ' : {$num} rn'); echo getmypid(), ': success rn'; //遞增$num $num = intval($num) + 1; } //寫入到共享內存段中 shmop_write($shmId, $num, 0); exit; }}//shmop_delete不會實際刪除該內存段,它將該內存段標記為刪除。shmop_delete($shmId);shmop_close($shmId);fclose($fp);
上述代碼的運行結果如下:
19923 : 2016-03-17 00:05:18 : 119923 : 2016-03-17 00:05:18 : 219923 : 2016-03-17 00:05:18 : 319923 : 2016-03-17 00:05:18 : 419923 : 2016-03-17 00:05:18 : 519924 : 2016-03-17 00:05:18 : 619924 : 2016-03-17 00:05:18 : 719924 : 2016-03-17 00:05:18 : 819924 : 2016-03-17 00:05:18 : 919924 : 2016-03-17 00:05:18 : 1019925 : 2016-03-17 00:05:18 : 1119925 : 2016-03-17 00:05:18 : 1219925 : 2016-03-17 00:05:18 : 1319925 : 2016-03-17 00:05:18 : 1419925 : 2016-03-17 00:05:18 : 15
這樣我們就在進程間共享了$num的數據。
更多關于PHP相關內容感興趣的讀者可查看本站專題:《PHP進程與線程操作技巧總結》、《PHP網絡編程技巧總結》、《PHP基本語法入門教程》、《PHP數組(Array)操作技巧大全》、《php字符串(string)用法總結》、《php+mysql數據庫操作入門教程》及《php常見數據庫操作技巧匯總》
希望本文所述對大家PHP程序設計有所幫助。
相關文章:
