求助：Perl多线程：全局变量无法push进值

swgaylz2008

#!/bin/perl
use IO::Socket;
use threads;
use strict;

my $ipHead="192.168.4.";
our @iplist=();
my @ips;
for(my $i=1;$i<255;$i++){push(@ips,$ipHead."$i");}

my $thread;
my @threads;
print localtime."\n";
for(my $j=0;$j<@ips;$j++){$threads[$j]=threads->new(\&portScaner,$ips[$j]);}
foreach my $threadinstance(@threads){$threadinstance->join();}
#foreach my $ip(@ips){&portScaner($ip);}
print localtime."\n";
print "@iplist\n";

#---------------------------------------------------------
#scan if the port 22 is open
sub portScaner{
my ($ip)=(shift);
my $result=IO::Socket::INET->new("$ip:22");
if($result){
print "$ip\n";
push(@iplist,$ip);
$result->close;
}
#else {writeLog("ip=$ip port 22 is not open!\n");}
}

这个程序如果用for循环执行@iplist数组中值是正确的，但是加上多线程后@iplist值输出时空的，求解：加lock（@iplist）；也不好使。

iamlimeng

1. use threads::shared;
   
2. 
   
3. our @iplist :shared=();

复制代码

swgaylz2008

回复 2# iamlimeng
为什么我加lock也不好使呢，求讲解


   

shijiang1130

shared搞起来

1. #!/bin/perl
   
2. use IO::Socket;
   
3. use threads;
   
4. use threads::shared;
   
5. use strict;
   
6. my $ipHead="127.0.0.";
   
7. my (@ips,@ipList) :shared;
   
8. my @threads;
   
9. 
   
10. for(1..255) {
    
11.         push(@ips,$ipHead."$_");
    
12.         }
    
13. 
    
14. print localtime."\n";
    
15. 
    
16. for(my $j=0;$j<@ips;$j++) {
    
17.         $threads[$j]=threads->new(\&portScaner,$ips[$j]);        }
    
18. 
    
19. foreach my $threadinstance (@threads) {
    
20.         $threadinstance->join();
    
21.         }
    
22. 
    
23. #foreach my $ip(@ips){&portScaner($ip);}
    
24. 
    
25. print localtime."\n";
    
26. 
    
27. #scan if the port 22 is open
    
28. sub portScaner{
    
29.                 my $ip = shift;
    
30.                 my $result = IO::Socket::INET->new("$ip:22");
    
31.                 if($result){
    
32.                                 print "$ip\n";
    
33.                                 push(@ipList,$ip);
    
34.                                 $result->close;
    
35.                 }
    
36. #else {writeLog("ip=$ip port 22 is not open!\n");}
    
37. }

复制代码

swgaylz2008

回复 4# shijiang1130
谢谢！可否给小弟讲解下shared和lock的区别。

swgaylz2008

#!/bin/perl
use IO::Socket;
use threads;
use threads::shared;
use DBI();
use strict;

#---------------------------------------------------------
#DB connection
my ($url,$user,$passwd)=("DBI:mysql:database=logserver;port=3306;host=127.0.0.1","root","123qwe");
our $dbh=DBI->connect($url,$user,$passwd) or die "can't connect DB mysql ".DBI->errstr;
my $ipHead="192.168.4.";
my (@ips,@iplist):shared;
our @logtype:shared=('test');
for(my $i=1;$i<255;$i++){push(@ips,$ipHead."$i");}

my @threads;
print localtime."\n";
for(my $j=0;$j<@ips;$j++){$threads[$j]=threads->new(\&portScaner,$ips[$j]);}
foreach my $threadinstance(@threads){$threadinstance->join();}
print localtime."\n";

#---------------------------------------------------------
#scan if the port 22 is open
sub portScaner{
my ($ip)=(shift);
my $result=IO::Socket::INET->new("$ip:22");
if($result){
push(@iplist,$ip);
foreach my $type(@logtype){&getLogtypeContext($type);}

$result->close;
}
#else {writeLog("ip=$ip port 22 is not open!\n");}
}
#---------------------------------------------------------
#get filepath keywords splitwords in logtype
sub getLogtypeContext{
my ($logtype)=@_;
my $sth=$dbh->prepare("select filepath,keyword,splitword from t_logtype where type='$logtype';") or die $dbh->errstr;
$sth->execute();
my (@filepath,@keyword,@splitword);
while(my $ref=$sth->fetchrow_hashref())
{
        push(@filepath,split(",",$ref->{filepath}));
        push(@keyword,split(",",$ref->{keyword}));       
        push(@splitword,split(",",$ref->{splitword}));             
}
return (\@filepath,\@keyword,\@splitword);
}
我现在想在多线程中使用DBI查询，dbh怎么设置shared呢，我现在这个提示无法shared？谢谢

回复 4# shijiang1130


   

anyevent

Perl的threads问题多，不稳定，速度也慢。楼主不如考虑用Coro（Perl的多线程）

swgaylz2008

谢谢，求写个简单的多线程示例！
回复 7# anyevent


   

anyevent

看看这里吧，有人翻译了中文文档
http://chenlinux.com/2012/06/29/coro-intro/

http://chenlinux.com/2012/11/18/coro/

swgaylz2008

谢大神！学习了。{:3_200:} 回复 9# anyevent