Perl的多进程框架(watcher-worker)

 1 #!/usr/bin/perl -w
 2 
 3 #author:pandaychen
 4 #date:2015-04-01
 5 #info:实现一个简单的多进程框架
 6 
 7 use strict;
 8 use warnings;
 9 use POSIX ":sys_wait_h";
10 
11 my $max_process = 20;
12 my $cur_process =0;
13 
14 my @pid_array;
15 
16 print "perl fork watcher-worker:\n";
17 
18 #main start here
19 CreateWorker($max_process);    
20 
21 #child start here
22 do_workers();
23 
24 sub CreateWorker{
25     my $workers=shift(@_);
26     print $workers,"\n";
27     
28         my $sign = 1;
29         
30         while($sign){
31             if($workers >0){
32                 my $pid = fork();
33                 if($pid >0){
34                     #watcher
35                     $sign = 1;
36                     --$workers;
37                 }
38                 elsif($pid == 0){
39                     #workers
40                     $sign = 0;
41                     print "create worker ",$$," success!\n" ;
42                     do_workers();
43                 }
44                 else
45                 {
46                     print "fork error: %s\n";
47                     return -1;
48                 }
49             }
50             else{
51                 #full workers
52                 my $nStatus;
53                 while ((my $collect = waitpid(-1, WNOHANG)) > 0)
54                 {
55                     print $collect," child process\n";
56                     $workers++;
57                 }
58             }
59         }
60     return 0;
61 }
62 
63 sub do_workers{
64     #模拟子进程工作
65     my $rand=int(rand(10));
66     sleep($rand);
67     print "child process sleep ",$rand," seconds.\n";
68     exit(1);
69 }