如何讓子進程向父進程傳輸數(shù)據(jù)

chinaseen

主進程派生200個左右的子進程，子進程處理完畢前，將數(shù)據(jù)傳給主進程，請問使用什么方法？能否給個例子？（是不是使用進程通信）

apile

看network programming with perl
找一下..里面有個parent與child用PIPE傳送資料的例子
改一下就是你要的了...

蘭花仙子

這種情況也就pipe最好了。parent用IO::Select把childs的寫pipe監(jiān)控起來，有數(shù)據(jù)就取出。

chinaseen

我試了一下PIPE,主進程中我使用ARRAY存儲這些數(shù)據(jù),但我打印時,系統(tǒng)提示ARRAY中只有一個元素.系統(tǒng)把所有的數(shù)據(jù)融入一個元素中了!這是為什么啊?
還有,不知道那么多子進程共同使用一個PIPE,會不會產(chǎn)生PIPE堵塞啊?

[ 本帖最后由 chinaseen 于 2006-11-22 10:19 編輯 ]

chinaseen

不知道使用PIPE與使用共享內(nèi)存相比,哪個的率更高?

蘭花仙子

原帖由 chinaseen 于 2006-11-22 10:10 發(fā)表
我試了一下PIPE,主進程中我使用ARRAY存儲這些數(shù)據(jù),但我打印時,系統(tǒng)提示ARRAY中只有一個元素.系統(tǒng)把所有的數(shù)據(jù)融入一個元素中了!這是為什么啊?
還有,不知道那么多子進程共同使用一個PIPE,會不會產(chǎn)生PIPE堵塞啊?

不會堵塞，子進程關(guān)閉讀管道，只寫；父進程關(guān)閉寫管道，只讀。
我說了要用IO::Select把pipe監(jiān)控起來。
另外，用hash來保存數(shù)據(jù)不是更好點么？用PID=>CONTENT這種形式。

chinaseen

謝謝仙子姐姐,我在子進程中關(guān)閉了READER,在主進程中也關(guān)閉了WRITER.
我使用ARRAY存儲,是由于將所有的子進程傳輸后,主進程要使用得到的數(shù)據(jù)進行匹配操作(grep),不管它是來自哪個子進程!所有我就沒有使用IO::select和HASH。這樣應(yīng)該也可以吧！

[ 本帖最后由 chinaseen 于 2006-11-22 10:57 編輯 ]

chinaseen

剛才跑了一下，最后管道被寫滿了。我是使用foreach和Parallel::ForkManager每次并發(fā)50個子進程運行的。foreach后面寫的是while(<READER>)來讀取管道的內(nèi)容。怎么能防止管道寫滿了？應(yīng)該在什么時候讀呢？

orangetouch

原帖由 chinaseen 于 2006-11-22 13:20 發(fā)表
剛才跑了一下，最后管道被寫滿了。我是使用foreach和Parallel::ForkManager每次并發(fā)50個子進程運行的。foreach后面寫的是while(<READER>)來讀取管道的內(nèi)容。怎么能防止管道寫滿了？應(yīng)該在什么時候讀呢？

用

1. IO::Select

復(fù)制代碼

apile

我的作法...從network programming with perl改的..

1. 
   
2. # create a pipe for IPC
   
3. pipe(CHILD_READ,CHILD_WRITE) or die "Can't make pipe!\n";
   
4. 
   
5. #-- Parent Process maintain read the input of child
   
6. my $IN = IO::Select->new(\*CHILD_READ);
   
7. $SIG{CHLD} = \&reap_child;
   
8. 
   
9. while(!$DONE){
   
10.   if($IN->can_read){    # get a message from one of the children
    
11.     my $message;
    
12.     next unless sysread(CHILD_READ,$message,4096);
    
13.     my @messages = split /\n/,$message;
    
14.     foreach (@messages){
    
15.        next unless my ($pid,$status) = /^(\d+) (.+)$/;
    
16.        if($status ne 'done'){
    
17.          $STATUS{$pid} = $status;
    
18.        }else{
    
19.          delete $STATUS{$pid};
    
20.        }
    
21.     }
    
22.   }
    
23.   print join(" ",map {"$_ => $STATUS{$_}"} keys %STATUS )."\n";
    
24.   #----- do nothing,if no child alive, -----
    
25.   unless(%CHILDREN){
    
26.      $normal = 1;
    
27.      last;
    
28.   }
    
29. }
    
30. ##-------假如非正常結(jié)束，必須刪除所有子程序
    
31. if($normal ==0){ kill_children(); exit 1;}
    
32. 
    

復(fù)制代碼