关于thread 中的 timeout的问题

yang200218

Hi,

请教大家一个关于thread的问题， 我想用多线程去获得多个机器的 CPU的load avg，使用rsh登录到机器上
执行uptime，
但是怎么处理 rsh的time out的问题？ 谢谢大家！


foreach my $machine (@$machines_set) {
        my $thr = threads->new(\&do_get_loadavg,$machine);
        push @local_threads,$thr;
}
foreach (@local_threads) {
        my $ret = $_->join();
        push @selected_mach,$ret;
}


sub do_get_loadavg {
    my $machine  = shift;
    my %ret_hash = ();

    my $out = '';

    eval {
        local $SIG{ALRM} = sub { die "Time out\n" };
        alarm $timeout;
        my $cmd = "rsh -l $user $machine uptime";
        $out = `/bin/sh -c '$cmd 2>&1'`;
        alarm(0);
    };
    if($@) {
        # errors in eval block
        # return a empty hash
        return \%ret_hash;
    } else {
        chomp $out;
        if ($out =~ /(.*)load\s+average\s*.*)/m) {
            my $load = $2;
            my @load_avg = split(/,/,$load);
            my $sum = 0;
            foreach my $val (@load_avg) {
                $sum += $val;
            }
            my $loadavg = $sum / 3;
            $ret_hash{$machine} = $loadavg;
        }
    }
    return \%ret_hash;
}

xiyoulaoyuanjia

1. eval {
   
2.     alarm(3600);
   
3.     # long-time operations here
   
4.     alarm(0);
   
5. };
   
6. 
   
7. if ($@) {
   
8.     if ($@ =~ /timeout/) {
   
9.                             # timed out; do what you will here
   
10.     } else {
    
11.         alarm(0);           # clear the still-pending alarm
    
12.         die;                # propagate unexpected exception
    
13.     }
    
14. }

复制代码

或者使用信号捕捉 省略 eval
或者   -t 选项
rsh server1 -l user1 -t 120 traceroute 192.168.1.245

yang200218

这个办法在进程中是可以的，但是在线程中，线程不能捕捉到timeout