有时候会产生僵尸进程, 帮忙分析一下

KevinLee39

我写的一个调度程序, 测试时有时候会产生僵尸进程(大概1/5的概率吧),  而且碰到这种情况, 主进程也停住不动了, 不知道停在哪里, 实在找不出原因了.

测试运行情况:
perl diaodu.pl cs 4
开始时间: 2010-10-03 15:19:11 pid: 7324 Version: 1.2.r33 2010-09-26
child 00 branch: 650100 pid: 7325 2010-10-03 15:19:11
child 01 branch: 650200 pid: 7326 2010-10-03 15:19:11
child 02 branch: 652100 pid: 7327 2010-10-03 15:19:11

另一个窗口里看进程的情况:
  xjv8js  7327  7324  1 15:19:11 pts/ts    0:00 <defunct>
  xjv8js  7325  7324  1 15:19:11 pts/ts    0:00 <defunct>
  xjv8js  7527 11176  0 15:24:15 pts/tk    0:00 grep 7324
  xjv8js  7328  7324  1 15:19:11 pts/ts    0:00 <defunct>
  xjv8js  7324  8015  0 15:19:11 pts/ts    0:00 perl diaodu.pl cs 4
  xjv8js  7326  7324  1 15:19:11 pts/ts    0:00 <defunct>

源码:

1. 
   
2. #! /usr/bin/perl
   
3. #
   
4. 
   
5. my @branch = qw(
   
6.         650100 650200 652100 652200 652300 652700 652800 652900
   
7.         653000 653100 653200 654000 654100 654200 654300 659000
   
8. );
   
9. 
   
10. my $startdate = '20100101'; # 采集开始日期
    
11. my $enddate   = '20100930'; # 采集结束日期
    
12. 
    
13. (our $REV = '$LastChangedRevision:: 33 ) =~ s/\D+(\d+)\D+/$1/g;
    
14. (our $REVDATE='$LastChangedDate:: 2010-09-26#)=~s/.+(\d{4}-\d\d-\d\d).+/$1/g;
    
15. (our $VERSION = '1.2.r'.$REV);
    
16. use warnings;
    
17. #use strict;
    
18. use Cwd;
    
19. use FindBin qw($Bin);
    
20. use POSIX;
    
21. use POSIX ":sys_wait_h";
    
22. 
    
23. sub usage {
    
24.         print "
    
25. Usage: $0 cj|sj|xz 并行进程个数
    
26.        cj 采集
    
27.        sj 审计
    
28.        xz 下载
    
29.    Ex: $0 cj 4
    
30. 
    
31. Version: $VERSION $REVDATE
    
32. 
    
33. ";
    
34. }
    
35. 
    
36. # 测试
    
37. my $cs =q#"date; sleep " . int(rand(40))#;
    
38. # 采集
    
39. my $cj =q#"sh collectdata.sh 1 $branch \\\\\# \\\\\# $startdate $enddate C O"#;
    
40. # 审计
    
41. my $sj =q#"cbps_4003_bat_AuditDataConsistency 1 $branch "#;
    
42. # 下载
    
43. my $xz =q#"cbps_4004_bat_DataDownLoad 1 $branch "#;
    
44. 
    
45. #
    
46. # main
    
47. #
    
48. if (@ARGV != 2 or ($ARGV[0] ne 'cs' and $ARGV[0] ne 'cj'
    
49.         and $ARGV[0] ne 'sj' and $ARGV[0] ne 'xz')) {
    
50.         &usage();
    
51.         exit(-1);
    
52. }
    
53. 
    
54. $|++;
    
55. my $mode     = $ARGV[0];        # 运行模式: 采集,下载等
    
56. my $binxindu = $ARGV[1];        # 希望的并行进程个数
    
57. my $child = 0;                        # 当前并行进程个数(正在跑的有几个)
    
58. my $position  = -1;                # 正在/已经采集的个数(采集到了哪个机构)
    
59. my $done_branch = 0;                # 已经采集完毕的个数
    
60. my $child_pid;
    
61. my %pid_branch;
    
62. 
    
63. print "开始时间: ".&get_time()." pid: $ Version: $VERSION $REVDATE\n";
    
64. 
    
65. my $sigset=POSIX::SigSet->new(&POSIX::SIGCHLD,&POSIX::SIGUSR1,&POSIX::SIGUSR2);
    
66. my $action = POSIX::SigAction->new('reaper',
    
67.                                    $sigset,
    
68.                                    0);
    
69. POSIX::sigaction(&POSIX::SIGCHLD, $action);
    
70. $action = POSIX::SigAction->new('add_binxindu',
    
71.                                 $sigset,        
    
72.                                 0);
    
73. POSIX::sigaction(&POSIX::SIGUSR1, $action);
    
74. $action = POSIX::SigAction->new('minus_binxindu',
    
75.                                 $sigset,        
    
76.                                 0);
    
77. POSIX::sigaction(&POSIX::SIGUSR2, $action);
    
78. 
    
79. # 启动
    
80. while(1) {
    
81.         &run();
    
82.         if ($done_branch == @branch) {
    
83.                 print "全部机构采集完毕\n";
    
84.                 print "结束时间: ".&get_time()."\n";
    
85.                 exit(0);
    
86.         }
    
87.         if ($binxindu == 0 && $child == 0) {
    
88.                 print "当前并行度为0, 完成的数量: $done_branch\n";
    
89.                 print "退出时间: ".&get_time()."\n";
    
90.                 exit(0);
    
91.         }
    
92.         pause();
    
93. }
    
94. # end main
    
95. 
    
96. #
    
97. # 按照当前并行度设定启动适当数量的子进程
    
98. #
    
99. sub run {
    
100.         while($child < $binxindu && $position+1 < @branch) {
     
101.                 &add_child();
     
102.         }
     
103. }
     
104. 
     
105. #
     
106. # 处理子进程终止
     
107. #
     
108. sub reaper {
     
109.         while (($child_pid = waitpid(-1,WNOHANG)) > 0) {
     
110.                 print "child $pid_branch{$child_pid} branch: "
     
111.                             ."$branch[$pid_branch{$child_pid}] pid: $child_pid "
     
112.                      .&get_time()." done\n";
     
113.                 $child--;
     
114.                 $done_branch++;
     
115.         }
     
116. }
     
117. 
     
118. #
     
119. # 增加一个并行度
     
120. #
     
121. sub add_binxindu {
     
122.         $binxindu++;
     
123.         print "add process to $binxindu\n";
     
124.         &run();
     
125.         print "child:           $child\n";
     
126.         print "done_branch:     $done_branch\n";
     
127. }
     
128. 
     
129. #
     
130. # 减少一个并行度
     
131. #
     
132. sub minus_binxindu {
     
133.         if ($binxindu > 0) {
     
134.                 $binxindu--;
     
135.         }
     
136.         print "minus binxindu to $binxindu\n";
     
137.         print "child:           $child\n";
     
138.         print "done_branch:     $done_branch\n";
     
139. 
     
140. }
     
141. 
     
142. #
     
143. # 增加一个并行进程
     
144. #
     
145. sub add_child {
     
146.         my $pid = fork;
     
147.         if (!defined($pid)) {
     
148.                 print "child branch: $branch[$position+1] fork failed!\n";
     
149.         } elsif ($pid > 0) {
     
150.                 # father process
     
151.                 $position++;
     
152.                 $pid_branch{"$pid"} = sprintf("%02d", $position);
     
153.                 print "child $pid_branch{$pid} branch: $branch[$position] "
     
154.                       ."pid: $pid ".&get_time()."\n";
     
155.                 $child++;
     
156.         } else {
     
157.                 # child process
     
158.                 open STDOUT, ">>$mode$branch[$position].log";
     
159.                 open STDERR, ">>&STDOUT";
     
160.                 my $commander = eval qq(eval "\$mode"); # mode前面是连续2个$符号, 帖子里发表不出来.
     
161.                 print "$commander\n"; exit(0);
     
162.                 #exec $commander;
     
163.         }
     
164. }
     
165. 
     
166. #
     
167. # 获取当前时间
     
168. #
     
169. sub get_time {
     
170.         my $time_str = strftime("%Y-%m-%d %H:%M:%S", localtime);
     
171.         return $time_str;
     
172. }
     
173. 
     

复制代码

sceyu

信号不排队的，错过了就没了。
应该是你在while的时候又信号进来，但是你错过了，所以产生了僵尸进程

jin2251138

楼主应该多看看大骆驼里面进程和信号2章