PERL共享内存的问题

dqchen0004

需求是这样的，使用fork创建10个子进程，每个子进程都去取得不同的值，然后将10个值相加得到最终的需求值，于是将10个值都传到数组里面，按照下面的代码写，却无论如何都只能得到一个值，请各位高手帮忙看看

1. use Data::Dumper;
   
2. use IPC::ShareLite;
   
3. use Storable qw(freeze thaw);
   
4. 
   
5.     my $share = IPC::ShareLite->new(
   
6.         -key     => 1971,
   
7.         -create  => 'yes',
   
8.         -destroy => 'no'
   
9.     ) or die $!;
   
10. 
    
11.     my @child;
    
12.     my @str;
    
13. for (my $i = 0;$i <= 10; $i++) {
    
14.     my $pid = fork();
    
15.     if ($pid) {
    
16.         push (@child,$pid);
    
17.     }
    
18.     else {
    
19.         push (@str,$i);
    
20.         $share->store(@str);
    
21.         exit 0;
    
22.     }
    
23. 
    
24. }
    
25. 
    
26. foreach my $pid (@child) {
    
27.         my $tmp = waitpid($pid,0);
    
28. }
    
29. 
    
30. @str = $share->fetch;
    
31. 
    
32. print Dumper(@str);

复制代码

nuclearxin

不懂fork
fork是什么意思啊?

dqchen0004

不懂fork
fork是什么意思啊?
nuclearxin 发表于 2010-03-25 17:44

    fork是进行进程复制的，多进程一般会用到fork

dqchen0004

没人解答一下吗？

toniz

回复 4# dqchen0004

store( $scalar )
This method stores $scalar into shared memory. $scalar may be arbitrarily long. Shared memory segments are acquired and released automatically as the data length changes. The only limits on the amount of data are the system-wide limits on shared memory pages (SHMALL) and segments (SHMMNI) as compiled into the kernel.

The method raises an exception on error.

Note that unlike IPC::Shareable, this module does not automatically allow references to be stored. Serializing all data is expensive, and is not always necessary. If you need to store a reference, you should employ the Storable module yourself. For example:

    use Storable qw( freeze thaw );
    ...
        $hash = { red => 1, white => 1, blue => 1 };
    $share->store( freeze( $hash ) );
    ...
    $hash = thaw( $share->fetch );

toniz

回复 5# toniz

1. use Data::Dumper;
   
2. use IPC::ShareLite;
   
3. use Storable qw(freeze thaw);
   
4. use IPC::ShareLite qw( :lock );
   
5. 
   
6. my $share = IPC::ShareLite->new(
   
7.   -key   => 1971,
   
8.   -create  => 'yes',
   
9.   -destroy => 'no'
   
10. ) or die $!;
    
11.   my @child;
    
12.   my @aa ;
    
13.         $share->store(freeze(\@aa));
    
14. for (my $i = 0;$i <= 10; $i++) {
    
15.   my $pid = fork();
    
16.   if ($pid) {
    
17.     push (@child,$pid);
    
18.   }
    
19.   else {
    
20.     $share->lock( LOCK_EX);
    
21.     $str = thaw( $share->fetch);
    
22.     push @{$str},$i;
    
23.     $share->store(freeze($str));
    
24.     $share->unlock;
    
25.     exit 0;
    
26.   }
    
27. }
    
28. foreach my $pid (@child) {
    
29.     my $tmp = waitpid($pid,0);
    
30. }
    
31. $str1 = thaw( $share->fetch);
    
32. print Dumper @{$str1};

复制代码