php 非阻塞mysql_php多进程中的阻塞与非阻塞操作实例分析
本文實(shí)例講述了php多進(jìn)程中的阻塞與非阻塞操作。分享給大家供大家參考,具體如下:
我們通過(guò)pcntl_fork來(lái)創(chuàng)建子進(jìn)程,使用pcntl_wait和pcntl_waitpid來(lái)回收子進(jìn)程。
子進(jìn)程退出后,父進(jìn)程沒(méi)有及時(shí)回收,就會(huì)產(chǎn)生僵尸進(jìn)程。
例1:
define('FORK_NUMS', 5);
$pids = array();
//我們創(chuàng)建5個(gè)子進(jìn)程
for($i = 0; $i < FORK_NUMS; ++$i) {
$pids[$i] = pcntl_fork();
if($pids[$i] == -1) {
die('fork error');
} else if ($pids[$i]) {
pcntl_wait($status);
} else {
echo getmypid() , " {$i} \r\n";
exit;
}
}
我們通過(guò)for循環(huán)fork出5個(gè)子進(jìn)程,父進(jìn)程會(huì)阻塞著等待子進(jìn)程退出,然后創(chuàng)建下一個(gè)子進(jìn)程。
上述代碼輸出結(jié)果如下:
20081 0
20082 1
20083 2
20084 3
20085 4
但我們創(chuàng)建多進(jìn)程的目的,就是為了能夠并行的處理任務(wù),阻塞的方式并不是我們想看到的。
例2:
define('FORK_NUMS', 5);
$pids = array();
//我們創(chuàng)建5個(gè)子進(jìn)程
for($i = 0; $i < FORK_NUMS; ++$i) {
$pids[$i] = pcntl_fork();
if($pids[$i] == -1) {
die('fork error');
} else if ($pids[$i]) {
pcntl_wait($status, WNOHANG);
} else {
echo getmypid() , " {$i} \r\n";
exit;
}
}
我們可以通過(guò)設(shè)置pcntl_wait的第二個(gè)參數(shù)為WNOHANG來(lái)控制進(jìn)程是否阻塞。
該函數(shù)可以在沒(méi)有子進(jìn)程退出的情況下立刻跳出執(zhí)行后續(xù)代碼。
pcntl_wait等同于以pid為-1調(diào)用pcntl_waitpid函數(shù)。
pcntl_waitpid函數(shù)可以等待指定pid的進(jìn)程。
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
總結(jié)
以上是生活随笔為你收集整理的php 非阻塞mysql_php多进程中的阻塞与非阻塞操作实例分析的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: mysql如何定义消耗资源多的sql语句
- 下一篇: java mysql 线程安全_java