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大型机执行了如上代码，机器内存足够大，出现了如下报错
Out of memory!
Segmentation fault (core dumped)
感觉数据量也不是非常大啊，怎么就内存溢出了，求助

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

你好，你这么做和我那么赋值，有什么区别么回复 2# walklan


   

wiliiwin

赞同楼上的，第一种是直接把所有的数据都读取到数组里面，也就是一次性读取到内存，这样数据要是很大的话，你内存不够肯定会出现问题，
第二种是每次读取一个数据，处理完就释放了，当然内存占用就小的多了。

清泉一边

赞同，我也觉得数组特别耗内存~

殇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