perl多線程內存溢出，段錯誤

殤19921011

#!/usr/bin/perl
#
use threads;
use Thread:ueue;
my $q = Thread:ueue->new();
my @array=(1..1000000);
  foreach $t(@array)
      {
             $book{$t}=$t*2;
#             printf("$name produce $book{$t}\n";
       }
foreach $r(sort keys %book)
    {
        $q->enqueue($r);
#       printf("$name produce $r\n";
    }
    $q->end();
sub consume {
open(outfile,">>syslog5";
    while(defined(my $r = $q->dequeue())) {
print outfile (localtime(time)."consume $r   @_.\n";
     }

}
sub consume2 {
  foreach $s(sort keys %book)
      {
              $r=$q->dequeue();
              printf("consume $r @_.\n";
          }
}
my $consumer1 = threads->create(\&consume, "consume1";
my $consumer2 = threads->create(\&consume, "consume2";
  my $consumer3 = threads->create(\&consume, "consume3";

  $consumer1->join();
  $consumer2->join();
    $consumer3->join();

在unix大型機執(zhí)行了如上代碼，機器內存足夠大，出現(xiàn)了如下報錯
Out of memory!
Segmentation fault (core dumped)
感覺數(shù)據(jù)量也不是非常大啊，怎么就內存溢出了，求助

zhlong8

這里內存不是問題。稍微改一點不和諧的地方，5.20 32位strawberryperl 最多占980M

1. use strict;
   
2. use warnings;
   
3. 
   
4. use threads;
   
5. use Thread::Queue;
   
6. 
   
7. my $q = Thread::Queue->new();
   
8. my %book;
   
9. 
   
10. my @array=(1..1000000);
    
11. 
    
12. for my $t (@array) {
    
13.     $book{$t}=$t*2;
    
14. }
    
15. 
    
16. for my $r (sort keys %book) {
    
17.     $q->enqueue($r);
    
18. }
    
19. 
    
20. $q->end();
    
21. 
    
22. sub consume {
    
23.     my $i = shift;
    
24.     open my $outfile, ">>syslog$i";
    
25.     while(defined(my $r = $q->dequeue)) {
    
26.         print $outfile (localtime(time)."consume $r   @_.\n");
    
27.     }
    
28. }
    
29. 
    
30. sub consume2 {
    
31.     for my $s (sort keys %book) {
    
32.         my $r = $q->dequeue;
    
33.         printf("consume $r @_.\n");
    
34.     }
    
35. }
    
36. my $consumer1 = threads->create(\&consume,1, "consume1");
    
37. my $consumer2 = threads->create(\&consume,2, "consume2");
    
38. my $consumer3 = threads->create(\&consume,3, "consume3");
    
39. 
    
40. $consumer1->join();
    
41. $consumer2->join();
    
42. $consumer3->join();
    

復制代碼

殤19921011

你好，你這么做和我那么賦值，有什么區(qū)別么回復 2# walklan


   

wiliiwin

贊同樓上的，第一種是直接把所有的數(shù)據(jù)都讀取到數(shù)組里面，也就是一次性讀取到內存，這樣數(shù)據(jù)要是很大的話，你內存不夠肯定會出現(xiàn)問題，
第二種是每次讀取一個數(shù)據(jù)，處理完就釋放了，當然內存占用就小的多了。

清泉一邊

贊同，我也覺得數(shù)組特別耗內存~

殤19921011

多謝回復 5# walklan


   

殤19921011

你好，這樣修改以后我增加為10個線程，還是報錯，內存溢出Out of memory!
Segmentation fault (core dumped)回復 5# walklan


   

殤19921011

你好，這樣修改以后我增加為10個線程，還是報錯，內存溢出Out of memory!
Segmentation fault (core dumped)回復 3# zhlong8