#! /usr/bin/perl -w
use threads;
use threads::shared;
use IO::Socket;

my $i  : shared;
my $cnt: shared;
my $total : shared;
$list 	 = 'newbase.txt';
$threads =  shift || 0;
$i 		 =  shift || 15500539;
$cnt 	 = 0;
$|   	 = 1;
$total	 = 0;


$time 	 = time; 
printf "Started at ".localtime()."\n";

for(0..$threads) {$trl[$_] = threads->create(\&par, $_);}
for(@trl) { $_->join; }

sub par
{
while($i)
	{
	{lock($i); $i--;}
	my $sock = new IO::Socket::INET 
		(
		PeerAddr => 'otvet.mail.ru',
   		PeerPort => 80, 
   		PeerProto => 'tcp', 
   		TimeOut => 20
		) or die "Can't connect\n";
	my $re = "GET http://otvet.mail.ru/question/$i/ HTTP/1.0\nHost: otvet.mail.ru\n".
		 "User-Agent: Mozilla/4.0 (compatible; MSIE 7.0b1; Windows NT 5.1; SV1; .NET CLR 1.1.4322; MS IdentiServ 1.4.12)\n".
		 "Connection: Close\nReferer: http://otvet.mail.ru\n\n";
	
	print $sock $re; 
	my $answ;
	while (defined($line = <$sock>)) {
        $answ .= $line;
    }
	
	open(FILE, ">>$list") || die("Could not open $list\n");
	while($answ =~ m/agent\?message\&to=(.*?)"/sg)
		{
		{lock($total); $total++;}
		print $1."\n";
		print FILE $1."\n";
		}
	close(FILE);
	{lock($cnt); $cnt++;}
	$percent = ($cnt/$i)*100;
	progress();
	}
}

$time = time-$time;
printf "Finished at".localtime()."\n";
printf "Time elapsed: $time sec\n";
printf "Found: $total \n";

sub progress{
print "|";
$percent = sprintf("%.2f", $percent);
print "< $percent% >\r";
	}