用Storable在多进程间共享数据

royalzhang

各位好，具体请见附上的代码，思路是用Storable，多个进程共享文件中保存的变量。但是，程序每次运行结果总是不同（不是打印顺序），10个数字总丢几个。请教是怎么回事呢？
谢谢！

1. # 将1到10共10个数字，用多个forkf放进一个共享的数组内，然后打印出来。为何每次运行结果不同，经常丢数字？
   
2. use strict;
   
3. use Parallel::ForkManager;
   
4. use Storable qw(store lock_store lock_retrieve);
   
5. 
   
6. my @aaa=();
   
7. store \@aaa, 'storable_file'; # initialize 'storable_file'
   
8. 
   
9. my @q=( 1 .. 10 );
   
10. 
    
11. my $pm = new Parallel::ForkManager(6);
    
12. foreach my $data (@q) {
    
13.     # Forks and returns the pid for the child:
    
14.     my $pid = $pm->start and next;
    
15.     my $aref = lock_retrieve('storable_file'); # read it
    
16.     push @$aref, $data;
    
17.     lock_store $aref, 'storable_file'; # put it back
    
18.     $pm->finish;    # Terminates the child process
    
19. }
    
20. $pm->wait_all_children;
    
21. 
    
22. my $aref = lock_retrieve('storable_file');
    
23. print join(", ", @$aref), "\n";
    
24. exit;
    

复制代码

zhlong8

是不是因为这个？

As with any advisory locking scheme, the protection only works if you systematically use lock_store and lock_retrieve . If one side of your application uses store whilst the other uses lock_retrieve , you will get no protection at all.

yybmsrs

执行了100次，没发现什么问题啊

royalzhang

回楼上两位：
1. 不是lock_store的原因，将第7行的store换成lock_store没有变化。
2. 每次运行的结果都不一样，比如：
user@server ~> perl t.pl
1, 2, 3, 6, 7, 8, 9, 10
user@server ~> perl t.pl
1, 2, 5, 6, 7, 8, 9, 10
user@server ~> perl t.pl
1, 2, 3, 4, 5, 6, 7, 8, 9, 10

yybmsrs

回复 4# royalzhang


    在windows下没问题，linux下确实有这个问题

yybmsrs

Likewise, "lock_retrieve" does the same as "retrieve", but also gets a shared lock on the file before reading.

可以多个进程同时读，每个读的都不一样，再保存的时候也不一样

cloud_vv

回复 6# yybmsrs


    额........................其实是因为你主线程执行太快造成的.....................你可以在jion 之前加一个sleep 2;就能清楚的看到相同的执行结果了.
(因而主线程执行太快,到你打印的时候所有的子进程都还没有完全把数据添加进去.............所以加一个sleep 2让主进程休眠一下,就不会有不同的结果了)