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的时候需要加参数。详细的看cpan的文档


 my $pid=threads->create({'context' => 'list'},$rfun,@para);
此条目发表在Perl Script分类目录,贴了, 标签。将固定链接加入收藏夹。

发表评论