php 的多進(jìn)程操作實(shí)踐案例分析
本文實(shí)例講述了php 的多進(jìn)程操作。分享給大家供大家參考,具體如下:
php的多進(jìn)程處理依賴于pcntl擴(kuò)展,通過(guò)pcntl_fork創(chuàng)建子進(jìn)程來(lái)進(jìn)行并行處理。
例1如下:
<?php $pid = pcntl_fork(); if($pid == -1) { //錯(cuò)誤處理:創(chuàng)建子進(jìn)程失敗時(shí)返回-1. die('fork error'); } else if ($pid) { //父進(jìn)程會(huì)得到子進(jìn)程號(hào),所以這里是父進(jìn)程執(zhí)行的邏輯 echo "parent \n"; //等待子進(jìn)程中斷,防止子進(jìn)程成為僵尸進(jìn)程。 pcntl_wait($status); } else { //子進(jìn)程得到的$pid為0, 所以這里是子進(jìn)程執(zhí)行的邏輯。 echo "child \n"; exit; }
pcntl_fork創(chuàng)建了子進(jìn)程,父進(jìn)程和子進(jìn)程都繼續(xù)向下執(zhí)行,而不同是父進(jìn)程會(huì)獲取子進(jìn)程的$pid也就是$pid不為零。而子進(jìn)程會(huì)獲取$pid為零。通過(guò)if else語(yǔ)句判斷$pid我們就可以在指定位置寫(xiě)上不同的邏輯代碼。
上述代碼會(huì)分別輸出parent和child。那么輸出的parent和child是否會(huì)有順序之分?是父進(jìn)程會(huì)先執(zhí)行?
例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; }
我們?cè)诟高M(jìn)程中通過(guò)sleep來(lái)延緩執(zhí)行,看看效果。
結(jié)果是,很快輸出了child,等待了接近3秒后,才輸出parent。所以父進(jìn)程和子進(jìn)程的執(zhí)行是相對(duì)獨(dú)立的,沒(méi)有先后之分。
那么問(wèn)題又來(lái)了?pcntl_wait是做什么用的?
會(huì)掛起當(dāng)前進(jìn)程,直到子進(jìn)程退出,如果子進(jìn)程在調(diào)用此函數(shù)之前就已退出,此函數(shù)會(huì)立刻返回。子進(jìn)程使用的資源將被釋放。
例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; }
上述代碼,我們可以看到,父進(jìn)程執(zhí)行pcntl_wait時(shí)就已經(jīng)掛起,直到等待3秒后輸出child,子進(jìn)程退出后。父進(jìn)程繼續(xù)執(zhí)行,輸出parent。
例4如下:
<?php define('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; } }
上述代碼,我們創(chuàng)建3個(gè)子進(jìn)程,父進(jìn)程分別掛起等待子進(jìn)程結(jié)束后,輸出parent。
輸出結(jié)果如下:
child id:19090
pernet
child id:19091
pernet
child id:19092
pernet
例5如下:
<?php define('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"; } }
輸出結(jié)果如下:
child id:19118
child id:19119
child id:19120
parent
parent
parent
為什么上述代碼跟例4的輸出結(jié)果不一樣?
我們可以看到例5的pcntl_waitpid函數(shù)放在了foreach中,foreach代碼是在主進(jìn)程中,也就是父進(jìn)程的代碼中。當(dāng)執(zhí)行foreach時(shí),可能子進(jìn)程已經(jīng)全部執(zhí)行完畢并退出。pcntl_waitpid會(huì)立刻返回,連續(xù)輸出三個(gè)parent。
(*在子進(jìn)程中,需通過(guò)exit來(lái)退出,不然會(huì)產(chǎn)生遞歸多進(jìn)程,父進(jìn)程中不需要exit,不然會(huì)中斷多進(jìn)程。)
例6如下:
<?php define('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} \r\n"); flock($fp, LOCK_UN); echo getmypid(), ": success \r\n"; ++$num; } exit; } } foreach($pids as $k => $v) { if($v) { pcntl_waitpid($v, $status); } } fclose($fp);
代碼如上:我們創(chuàng)建三個(gè)子進(jìn)程,來(lái)同時(shí)向test.log文件寫(xiě)入內(nèi)容,test.log內(nèi)容如下:
19507 : 2016-03-16 20:40:52 : 1
19507 : 2016-03-16 20:40:52 : 2
19507 : 2016-03-16 20:40:52 : 3
19507 : 2016-03-16 20:40:52 : 4
19507 : 2016-03-16 20:40:52 : 5
19509 : 2016-03-16 20:40:52 : 1
19509 : 2016-03-16 20:40:52 : 2
19509 : 2016-03-16 20:40:52 : 3
19509 : 2016-03-16 20:40:52 : 4
19509 : 2016-03-16 20:40:52 : 5
19508 : 2016-03-16 20:40:52 : 1
19508 : 2016-03-16 20:40:52 : 2
19508 : 2016-03-16 20:40:52 : 3
19508 : 2016-03-16 20:40:52 : 4
19508 : 2016-03-16 20:40:52 : 5
我們可以看到三個(gè)子進(jìn)程的pid,它們分別執(zhí)行了5次,時(shí)間幾乎是在同時(shí)。但是$num的值并沒(méi)像我們期望的那樣從1-15進(jìn)行遞增。子進(jìn)程中的變量是各自獨(dú)立的,互不影響。子進(jìn)程會(huì)自動(dòng)復(fù)制父進(jìn)程空間里的變量。
如何在進(jìn)程中共享數(shù)據(jù)?
我們通過(guò)php的共享內(nèi)存函數(shù)shmop來(lái)實(shí)現(xiàn)。
<?php define('FORK_NUMS', 3); $pids = array(); $fp = fopen('./test.log', 'wb'); $num = 1; //共享內(nèi)存段的key $shmKey = 123; //創(chuàng)建共享內(nèi)存段 $shmId = shmop_open($shmKey, 'c', 0777, 64); //寫(xiě)入數(shù)據(jù)到共享內(nèi)存段 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]) { //阻塞,等待子進(jìn)程退出 //注意這里,如果是非阻塞的話,$num的計(jì)數(shù)會(huì)出現(xiàn)問(wèn)題。 pcntl_waitpid($pids[$i], $status); } else { //讀取共享內(nèi)存段中的數(shù)據(jù) $num = shmop_read($shmId, 0, 64); for($i = 0; $i < 5; ++$i) { fwrite($fp, getmypid() . ' : ' . date('Y-m-d H:i:s') . " : {$num} \r\n"); echo getmypid(), ": success \r\n"; //遞增$num $num = intval($num) + 1; } //寫(xiě)入到共享內(nèi)存段中 shmop_write($shmId, $num, 0); exit; } } //shmop_delete不會(huì)實(shí)際刪除該內(nèi)存段,它將該內(nèi)存段標(biāo)記為刪除。 shmop_delete($shmId); shmop_close($shmId); fclose($fp);
上述代碼的運(yùn)行結(jié)果如下:
19923 : 2016-03-17 00:05:18 : 1
19923 : 2016-03-17 00:05:18 : 2
19923 : 2016-03-17 00:05:18 : 3
19923 : 2016-03-17 00:05:18 : 4
19923 : 2016-03-17 00:05:18 : 5
19924 : 2016-03-17 00:05:18 : 6
19924 : 2016-03-17 00:05:18 : 7
19924 : 2016-03-17 00:05:18 : 8
19924 : 2016-03-17 00:05:18 : 9
19924 : 2016-03-17 00:05:18 : 10
19925 : 2016-03-17 00:05:18 : 11
19925 : 2016-03-17 00:05:18 : 12
19925 : 2016-03-17 00:05:18 : 13
19925 : 2016-03-17 00:05:18 : 14
19925 : 2016-03-17 00:05:18 : 15
這樣我們就在進(jìn)程間共享了$num的數(shù)據(jù)。
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《PHP進(jìn)程與線程操作技巧總結(jié)》、《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《PHP基本語(yǔ)法入門教程》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫(kù)操作入門教程》及《php常見(jiàn)數(shù)據(jù)庫(kù)操作技巧匯總》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
相關(guān)文章
php對(duì)mongodb的擴(kuò)展(初出茅廬)
我們的php mongodb也能做mysql、sqlserver能做的幾乎所有功能,本文將詳細(xì)介紹2012-11-11關(guān)于PHP求解三數(shù)之和問(wèn)題詳析
這篇文章主要給大家介紹了關(guān)于PHP求解三數(shù)之和問(wèn)題的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-11-11PHP中把對(duì)象轉(zhuǎn)換為關(guān)聯(lián)數(shù)組代碼分享
這篇文章主要介紹了PHP中把對(duì)象轉(zhuǎn)換為關(guān)聯(lián)數(shù)組代碼分享,本文直接給出實(shí)現(xiàn)代碼,需要的朋友可以參考下2015-04-04PHP高效處理前端數(shù)據(jù)過(guò)濾二維數(shù)組并存入數(shù)據(jù)庫(kù)
這篇文章主要介紹了PHP高效處理前端數(shù)據(jù)過(guò)濾二維數(shù)組并存入數(shù)據(jù)庫(kù),通過(guò)從二維數(shù)組獲取指定數(shù)據(jù),組成新二維數(shù)組實(shí)現(xiàn)過(guò)程示例來(lái)為大家講解2023-10-10解決PHP 7編譯安裝錯(cuò)誤:cannot stat ‘phar.phar’: No such file or direc
這篇文章主要給大家介紹了關(guān)于解決在PHP 7編譯安裝遇到的錯(cuò)誤錯(cuò)誤:cannot stat ‘phar.phar’: No such file or directory問(wèn)題的相關(guān)資料,文中給出詳細(xì)的解決方法,需要的朋友可以參考借鑒。2017-02-02