本文目的
本文通过例子讲解linux环境下，使用php进行并发任务处理，以及如何通过pipe用于进程间的数据同步。写得比较简单，作为备忘录。
PHP多进程
通过pcntl_XXX系列函数使用多进程功能。注意：pcntl_XXX只能运行在php CLI（命令行）环境下，在web服务器环境下，会出现无法预期的结果，请慎用！
管道PIPE
管道用于承载简称之间的通讯数据。为了方便理解，可以将管道比作文件，进程A将数据写到管道P中，然后进程B从管道P中读取数据。php提供的管道操作API与操作文件的API基本一样，除了创建管道使用posix_mkfifo函数，读写等操作均与文件操作函数相同。当然，你可以直接使用文件模拟管道，但是那样无法使用管道的特性了。
僵尸进程
子进程结束时，父进程没有等待它（通过调用wait或者waitpid）,那么子进程结束后不会释放所有资源（浪费呀！），这种进程被称为僵尸进程，他里面存放了子进程结束时的相关数据，如果僵尸进程过多，会占用大量系统资源（如内存），影响机器性能。
代码
废话少说直接上代码
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
/**
* 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
);
}
|
ok，完毕，注释写的比较清除，执行结果如下：
声明：如有转载本博文章，请注明出处。您的支持是我的动力！文章部分内容来自互联网，本人不负任何法律责任。
本文转自bourneli博客园博客，原文链接：http://www.cnblogs.com/bourneli/archive/2012/07/06/2579893.html
，如需转载请自行联系原作者
