本文通过例子讲解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多进程处理并行任务的详细内容。