Perl - 跨线程的数组哈希

Question

我是 Perl 的初学者，但必须开发一些脚本来解析 TCP-dump。 在这里（我将其截断并仅留下相关代码）：

我收到以下错误： 线程 1 异常终止：TestThread1.pl 第 16 行的共享标量值无效， 这是因为这个字符串： %input = (%input, $fix_ClOrdID => [$FrameTime_epoch,$fix_MsgType]);

从我读过的许多类似主题中，我了解到我无法使用 threads::shared 共享嵌套引用。而且我还找到了一些解决方法。但由于缺乏经验，我无法为我的案例应用示例。

您能否建议如何修复我的脚本以使其正常工作！

use threads;
use threads::shared;
my %input:shared = ();
threads->new(\&FixParser)->detach();

sub FixParser{  
 open(InFile, 'myFix.dmp') || die;
 while(InFile>){
  ($FrameTime_epoch,$fix_MsgType,$fix_ClOrdID) = split(';',);
  if(exists($input{$fix_ClOrdID})){
   $ExecDelay=$FrameTime_epoch-$input{$fix_ClOrdID}[0];
   print "MsgType: $input{$fix_ClOrdID}[1] ExecDelay: $ExecDelay us\n";
   delete($input{$fix_ClOrdID});
  }
  else{
   %input = (%input, $fix_ClOrdID => [$FrameTime_epoch,$fix_MsgType]);
  }
 }
} 

Answer 1

在添加到哈希之前锁定您的共享变量和克隆结构，

sub FixParser {  
  open(my $InFile, "<", 'myFix.dmp') || die $!;
  while(<$InFile>) {

    ADVISORY_LOCK: {
      lock(%input);
      # ..
      if(exists($input{$fix_ClOrdID})) {
        # ..
      }
      else{
       # %input = (%input, $fix_ClOrdID => [$FrameTime_epoch,$fix_MsgType]);
       $input{ $fix_ClOrdID } = threads::shared::shared_clone( [$FrameTime_epoch,$fix_MsgType] );
      }
    }

  }
}