perl muti-threading里傳全局變量hash reference

turningA

各位好！首次發(fā)帖。多多指教！
請教一個關(guān)于multithreading里傳遞參數(shù)的問題。

當我不用multithreading的時候，以下是work的。
Version 1:

1. 
   
2. my %readMap1;
   
3. parseInputFile(\%readMap1,$inFileName1,$end1);
   
4. my %readMap2;
   
5. parseInputFile(\%readMap2,$inFileName2,$end2);
   
6. 
   
7. sub parseInputFile
   
8. {
   
9.                   my ($readMapRef, $file, $anchor) = @_;
   
10.                 ...
    
11. }
    

復制代碼

當我用multithreading的時候，以下是不work的。
Version 2:

1. 
   
2. my %readMap1;
   
3. my @Threadsinput=();
   
4. my $trd= threads -> new ( sub {parseInputFile(\%readMap1,$inFileName1,$end1)} );
   
5. push (@Threadsinput, $trd);
   
6. my %readMap2;
   
7. my $trd= threads -> new ( sub {parseInputFile(\%readMap2,$inFileName2,$end2)} );
   
8. push (@Threadsinput, $trd);
   
9. foreach my $thr (@Threadsinput)
   
10. {
    
11.         print $thr->tid, " threadID\n";
    
12.         $thr->join;
    
13. }
    
14. sub parseInputFile
    
15. {
    
16.                   my ($readMapRef, $file, $anchor) = @_;
    
17.                 ...
    
18. }
    

復制代碼

單步調(diào)試顯示join后兩個hashes 都是空的。

于是我換了一個思路：通過子程序返回值把hash返回，以下是work的，。
version 3：

1. 
   
2. my %readMap1;
   
3. my @Threadsinput=();
   
4. my $trd= threads -> new ( sub {parseInputFile($inFileName1,$end1)} );
   
5. push (@Threadsinput, $trd);
   
6. my %readMap2;
   
7. my $trd= threads -> new ( sub {parseInputFile($inFileName2,$end2)} );
   
8. push (@Threadsinput, $trd);
   
9. my @mapArr=();
   
10. foreach my $thr (@Threadsinput)
    
11. {
    
12.         my $mapHashRef=$thr->join;
    
13.         push @mapArr, \%{$mapHashRef};
    
14. }
    
15. 
    
16. sub parseInputFile
    
17. {
    
18.                   my ( $file, $anchor) = @_;
    
19.                 my %readMapRef=();
    
20.                 ...
    
21.                 ##in this subroutine, I will write something into this hash: %readMapRef
    
22.                 [b]return \%readMapRef;[/b]
    
23. 
    
24. }
    

復制代碼

我的問題是： 為什么把全局變量hash以引用的方式傳入子函數(shù)，并把子程序multithreading，不work呢？

chenhao392

哈哈哈，歡迎turningA...

我拉了一個Bioinfo的來Perl版！

sjdy521

perl的多線程模型默認數(shù)據(jù)是不共享的，threads::shared

turningA

回復 3# sjdy521

因為速度的考慮，我避免了在多線程里共享數(shù)據(jù)。
我定義了兩個不同的hash，也就是兩個線程分別往不同的hash里寫數(shù)據(jù)。


   

sjdy521

這樣速度也一樣上不去 不要共享就追求速度 你可以改成perl多進程方式了

turningA

回復 5# sjdy521

哦？請展開講講？多進程是說的是fork么？

我的原意是lock free的多線程可在速度上稍稍提高些，避免了大家共同訪問同一個引用而需要等待的時間。
   

sjdy521

回復 6# turningA


    避免cow可以一定程度提升速度，但perl的多線程本身就性能不行，你根本不需要多線程共享的話。就直接用多進程就可以了，多進程是指fork

turningA

回復 2# chenhao392


    :wink: