本文透過例子說明linux環境下，使用php進行並發任務處理，以及如何透過pipe用於進程間的資料同步。寫得比較簡單，作為備忘錄。
PHP多進程
透過pcntl_XXX系列函數使用多進程功能。注意：pcntl_XXX只能運行在php CLI（命令列）環境下，在web伺服器環境下，會出現無法預期的結果，請慎用！
管道PIPE
管道用於承載簡稱之間的通訊資料。為了方便理解，可以將管道比喻為文件，進程A將資料寫到管道P中，然後進程B從管道P中讀取資料。 php提供的管道操作API與操作文件的API基本上一樣，除了建立管道使用posix_mkfifo函數，讀寫等操作都與檔案操作函數相同。當然，你可以直接使用檔案模擬管道，但是那樣無法使用管道的特性了。
殭屍行程
子程序結束時，父行程沒有等待它（透過呼叫wait或waitpid）,那麼子行程結束後不會釋放所有資源（浪費呀！），這種進程被稱為殭屍進程，他裡面存放了子進程結束時的相關數據，如果殭屍進程太多，會佔用大量系統資源（如記憶體），影響機器效能。
程式碼
/**
* this is a demo for php fork and pipe usage. fork use
* to create child process and pipe is used to sychoroize
* the child process and its main process.
* @author bourneli
* @date: 2012-7-6
*/
define("PC", 10); // 进程个数
define("TO", 4); // 超时
define("TS", 4); // 事件跨度，用于模拟任务延时
if (!function_exists('pcntl_fork')) {
die("pcntl_fork not existing");
}
// 创建管道
$sPipePath = "my_pipe.".posix_getpid();
if (!posix_mkfifo($sPipePath, 0666)) {
die("create pipe {$sPipePath} error");
}
// 模拟任务并发
for ($i = 0; $i < PC; ++$i ) {
$nPID = pcntl_fork(); // 创建子进程
if ($nPID == 0) {
// 子进程过程
sleep(rand(1,TS)); // 模拟延时
$oW = fopen($sPipePath, 'w');
fwrite($oW, $i."\n"); // 当前任务处理完比，在管道中写入数据
fclose($oW);
exit(0); // 执行完后退出
}
}
// 父进程
$oR = fopen($sPipePath, 'r');
stream_set_blocking($oR, FALSE); // 将管道设置为非堵塞，用于适应超时机制
$sData = ''; // 存放管道中的数据
$nLine = 0;
$nStart = time();
while ($nLine < PC && (time() - $nStart) < TO) {
$sLine = fread($oR, 1024);
if (empty($sLine)) {
continue;
}
echo "current line: {$sLine}\n";
// 用于分析多少任务处理完毕，通过‘\n’标识
foreach(str_split($sLine) as $c) {
if ("\n" == $c) {
++$nLine;
}
}
$sData .= $sLine;
}
echo "Final line count:$nLine\n";
fclose($oR);
unlink($sPipePath); // 删除管道，已经没有作用了
// 等待子进程执行完毕，避免僵尸进程
$n = 0;
while ($n < PC) {
$nStatus = -1;
$nPID = pcntl_wait($nStatus, WNOHANG);
if ($nPID > 0) {
echo "{$nPID} exit\n";
++$n;
}
}
// 验证结果，主要查看结果中是否每个任务都完成了
$arr2 = array();
foreach(explode("\n", $sData) as $i) {// trim all
if (is_numeric(trim($i))) {
array_push($arr2, $i);
}
}
$arr2 = array_unique($arr2);
if ( count($arr2) == PC) {
echo 'ok';
} else {
echo "error count " . count($arr2) . "\n";
var_dump($arr2);
}相關推薦：
#以上是PHP多行程處理平行任務的詳細內容。更多資訊請關注PHP中文網其他相關文章！
