sysread / coro-processpool Goto Github PK

use Coro::ProcessPool;                                                          
use 5.010;                                                                      
use YAML 'Dump';                                                                
use Mojo::UserAgent;                                                            

my $ua = Mojo::UserAgent->new;                                                  
say $ua->get('m.hupu.com')->res->code;                                          
my $pool = Coro::ProcessPool->new(                                              
    max_procs => 4,                                                             
    max_reqs  => 100,                                                           
);                                                                              

my $double = sub {                                                              
    $ua->get(                                                                   
        'hoopchina.com' => sub {                                                
            say $_[1]->res->code;                                               
        }                                                                       
    );                                                                          
    return 1;                                                                   
};                                                                              

# Defer waiting for result                                                      
my %deferred = map { $_ => $pool->defer( $double, [$_] ) } ( 1 .. 1000 );       
foreach my $i ( keys %deferred ) {                                              
    print "$i = " . $deferred{$i}->() . "\n";                                   
}                                                                               

$pool->shutdown;