perl多线程实例

今天突然想起把自己之前写的一个脚本换成多线程的模式改写一下，因为之前的模式很多时间都阻塞住了，每次批量搞几千个机器太费时。
先是使用老的Thread模块把脚本改写的一遍，都把脚本写好了验证OK才发现这个是老的模块，不推荐使用，肺都气炸了。还好新的threads模块也类似，简单修改了一下也OK，而且新模块的功能强大很多，可靠性也好。测试一下

#!/usr/bin/perl  
use strict;  
use warnings;  
use threads;  
my @test=(1...988);  
srand();  
&muti_work;  
  
  
sub muti_work(){  
my $JOBN=30;  
my $jobs=0;  
while(@test){  
if($jobs<$JOBN && $jobs>=0) {  
my $pid=threads->create(\&echon,shift @test);  
$jobs++;  
} elsif($jobs>=$JOBN) {  
my @actlist=threads->list(threads::joinable);  
foreach my $t (@actlist) {  
$t->join;  
$jobs--;  
}  
sleep 0.1;  
  
}  
}  
  
while($jobs>0) {  
my @actlist=threads->list(threads::joinable);  
foreach my $t(@actlist){  
$t->join;  
$jobs--;  
}  
sleep 0.5;  
}  
}  
sub echon(){  
my $num=shift;  
my $t=int(rand(8));  
sleep $t;  
my  $thr = threads->self();  
print "i am working $num sleep $t\n";  
threads->exit(0);  
}  
print "ok\n";

如果涉及到每个线程都有一个返回值的话，可以在函数里面直接运行return就行。使用my $vat=$t->join的形式进行返回值的获取。如果返回的是一个数组，也是可以直接return @list的，但是thread->create的时候需要加参数。详细的看http://search.cpan.org/~jdhedden/threads-1.86/lib/threads.pm。

my $pid=threads->create({'context' => 'list'},$rfun,@para);