perl的多线程脚本示例

于一

#!/usr/bin/perl -w
use strict;
use Data::Dumper;
use POSIX;
use Getopt::Long;
use threads ('exit' => 'threads_only');
use List::Util 'shuffle';
use Thread::Semaphore;
use threads::shared;
use File::Basename;
##设置并行线程数
my $semaphore_cnt = Thread::Semaphore->new(100);
my @hosts = ();
open (HOSTFILE,"</home/hdfs/lxw/mapred.hosts") or die "failed to open hostfiles to read\n";
while (<HOSTFILE>) {
chomp;
push @hosts,$_;
}
close HOSTFILE;

foreach my $host (@hosts) {
$semaphore_cnt->down();
my $t = threads->create(\&deleteFiles,$host);
foreach my $thr (threads->list(threads::joinable)){
$thr->join();
}
}

foreach my $thr (threads->list()){
$thr->join();
}
sub deleteFiles() {
my $host = $_[0];
my $command = qq(source /etc/profile
source /etc/bashrc
ssh $host -p 58422 -t 'sudo nohup sh /tmp/del.sh'
);
my $start_time = &getNowTime();
my $result = system($command);
my $end_time = &getNowTime();
if ("$result" eq "0") {
&wirteLog($host . "  start:" . $start_time . " end:" . $end_time . "\n");
$semaphore_cnt->up();
} else {##failed
$semaphore_cnt->up();
}
}

sub getNowTime {
my ($sec,$min,$hour,$day,$mon,$year) = (localtime(time))[0,1,2,3,4,5];
sprintf "%4d-%02d-%02d %02d:%02d:%02d",$year+1900,$mon+1,$day,$hour,$min,$sec;
}
sub wirteLog {
my ($msg) = @_;
my $logFile = "/tmp/delete_tobedeleted.log";
open LOGFILE,">>$logFile" or die "failed to open $logFile to write\n";
print LOGFILE $msg;
close LOGFILE;
}