PHP中利用pcntl进行多进程并发控制
pcntl_fork可以很方便的创建进程，对于一般的需要固定的多进程处理的应用场景来说，实现比较简单，但是，对于需要大量并发创建子进程的应用场景来说，主要的问题在于会产生大量的僵尸进程。。。
我们的应用中，之前是采用将过程中产生的子进程pid收集起来， 间隔一定时间统一回收（pcntl_waitpid），这样带来的一个问题是：在大量并发情况下，服务器压力过大，会导致子进程“死掉”，这个时候，子进程不是僵尸，无法回收掉，主控进程就卡在那里不动了。。。
今天借鉴了一下“http://www.perkiset.org/forum/php/forked_php_daemon_example-t474.0.html”文中的方式，用二次创建进程的方式（孙进程处理业务）来将子进程交给系统，达到了在父进程中不需要wait真正的业务子进程的目的，也更接近其他语言中的线程并发控制:
我们原来的子进程创建接口：
1. /**
2. * author: selfimpr
3. * blog:
4. * mail: lgg860911@yahoo.com.cn
5. */
6. function new_child($func_name) {
7. $args = func_get_args();
8. $args[0]);
9. $pid = pcntl_fork();
10. if($pid == 0) {
11. $func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);
12. else if($pid == -1) {
13. echo "Couldn’t create child process.";
14. else {
15. return $pid;
16. }
17. }
新的方式：
1. <?php
2. /**
3. * author: selfimpr
4. * blog:
5. * mail: lgg860911@yahoo.com.cn
6. */
7. function daemon($func_name) {
8. $args = func_get_args();
9. $args[0]);
10. $pid = pcntl_fork();
11. if($pid) {
12. $status);
13. else if($pid == -1) {
14. echo "Couldn't create child process.";
15. else {
16. $pid = pcntl_fork();
17. if($pid == 0) {
18. posix_setsid();
19. $func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);
20. else if($pid == -1) {
21. echo "Couldn’t create child process.";
22. else {
23. exit;
24. }
25. }
26. }
27. ?>
新方式的完整测试：
测试方法：cli模式下运行， ps -ef | grep php查看过程中的php进程情况
1. <?php
2. /**
3. * author: selfimpr
4. * blog:
5. * mail: lgg860911@yahoo.com.cn
6. */
7. function daemon($func_name) {
8. $args = func_get_args();
9. $args[0]);
10. $pid = pcntl_fork();
11. if($pid) {
12. $status);
13. else if($pid == -1) {
14. echo "Couldn't create child process.";
15. else {
16. $pid = pcntl_fork();
17. if($pid == 0) {
18. posix_setsid();
19. $func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);
20. else if($pid == -1) {
21. echo "Couldn’t create child process.";
22. else {
23. sleep(5);
24. exit;
25. }
26. }
27. }
28. function test() {
29. while($i ++ < 10) {
30. echo "child process $i/n";
31. sleep(1);
32. }
33. }
34. daemon(test);
35. while(++ $j) echo "parent process $j/n";
36. ?>