multithreading - 如何编写多线程Perl脚本来编写日志文件？

Question

需要不时地更新日志文件。这里的问题是，如果我使用多线程来写相同的日志文件，我可能会看到一些行不正确。

my $date_string = strftime "%Y%m%d\_%H\_%M\_%S",localtime;

open(LOG,"+>","log\_$date_string.log")or die "cant open the file";


for ($count = 1; $count <=$thread_count ; $count++) 
{
    my $thread = threads->new(\&process);
    push(@threads,$thread);        

}

foreach (@threads) 
{
   $_->join;
}
close LOG;

sub process
{  ......
   ......
   print LOG "$datestring"."\|$process_id\|$host\|$port\|input\|Processing $filename\|\n";
}

对于上面的代码，iam的输出如下:

2014-05-20 12:12:46|19903|172.16.7.109|2000|input|Processing /opt/search_command/_13668.out|
2014-05-20 12:12:47|19903|172.16.7.109|2000|search|Processing /opt/search_command/_13668.out|0.940|
5-20 12:12:46|19903|172.16.7.109|2000|input|Processing /opt/search_command/_11061.out|
2014-05-20 12:12:47|19903|172.16.7.109|2000|search|Processing /opt/search_command/_11061.out|0.952|

如果您看到第三行日期未正确打印

我需要一个有关如何在Perl中使用多线程在日志文件中记录状态的解决方案。

提前致谢

Answer 1

您可以在写入之前锁定文件，然后在释放之后释放锁定。

sub process {  
   lock(\*LOG);
   print LOG ..
   unlock(\*LOG);
}


use Fcntl qw(:flock SEEK_END);

sub lock {
  my ($fh) = @_;
  flock($fh, LOCK_EX) or die $!;
  seek($fh, 0, SEEK_END) or die $!;
}
sub unlock {
  my ($fh) = @_;
  flock($fh, LOCK_UN) or die $!;
}