#!/usr/bin/perl -w<\/span><\/div>use<\/span> strict<\/span>;<\/span><\/div> <\/div>
use<\/span> Event::<\/span>Lib<\/span>;<\/span><\/div>use<\/span> Data::<\/span>Dumper<\/span>;<\/span><\/div> <\/div>
use<\/span> MysqlAsync<\/span>;<\/span><\/div>use<\/span> AsyncCaller<\/span> qw<\/span>/schedule/<\/span>;<\/span><\/div> <\/div>
$<\/span>Data::Dumper::<\/span>Terse<\/span> =<\/span> 1<\/span>;<\/span><\/div> <\/div>
$|<\/span>=<\/span>1<\/span>;<\/span><\/div> <\/div>
my<\/span> $expected_results<\/span> =<\/span> 25<\/span>;<\/span><\/div>my<\/span> $results<\/span> =<\/span> 0<\/span>;<\/span><\/div> <\/div>
my<\/span> $dbh<\/span>;<\/span><\/div> <\/div>
for<\/span> (<\/span>1<\/span>..<\/span>$expected_results<\/span>)<\/span> {<\/span><\/div> my<\/span> $secs<\/span> =<\/span> rand<\/span>(<\/span>5<\/span>);<\/span><\/div> my<\/span> $query<\/span> =<\/span> qq[select sleep($secs)]<\/span>;<\/span><\/div> schedule<\/span>(<\/span>0<\/span>.<\/span>001<\/span>,<\/span> sub<\/span>{<\/span><\/div> my<\/span> $dbh<\/span> =<\/span> MysqlAsync<\/span>-><\/span>new<\/span>(<\/span><\/div> database<\/span> =><\/span> {<\/span><\/div> host<\/span> =><\/span> "localhost"<\/span>,<\/span><\/div> port<\/span> =><\/span> 3306<\/span>,<\/span><\/div> database<\/span> =><\/span> "mysql"<\/span>,<\/span><\/div> passwd<\/span> =><\/span> "xxxxxxxx"<\/span>,<\/span><\/div> user<\/span> =><\/span> "root"<\/span>,<\/span><\/div> },<\/span><\/div> connect_timeout<\/span> =><\/span> 1<\/span>,<\/span><\/div> max_requests<\/span> =><\/span> 25<\/span>,<\/span><\/div> db_timeout<\/span> =><\/span> 10<\/span>,<\/span><\/div> );<\/span><\/div> <\/div>
$dbh<\/span>-><\/span>get_array<\/span>(<\/span>$query<\/span>,<\/span> \\&<\/span>result<\/span> );<\/span><\/div> });<\/span><\/div>}<\/span><\/div> <\/div>
event_mainloop<\/span>();<\/span><\/div> <\/div>
exit<\/span>;<\/span><\/div> <\/div>
sub <\/span>result<\/span><\/div>{<\/span><\/div> my<\/span> (<\/span>$result<\/span>)<\/span> =<\/span> @_<\/span>;<\/span><\/div> if<\/span> (<\/span>defined<\/span> $result<\/span>)<\/span> {<\/span><\/div> print<\/span> "result: "<\/span> .<\/span> Dumper<\/span>(<\/span>$result<\/span>);<\/span><\/div> }<\/span> else<\/span> {<\/span><\/div> print<\/span> "error: "<\/span> .<\/span> Dumper<\/span>(<\/span>$dbh<\/span>-><\/span>error<\/span>());<\/span><\/div> }<\/span><\/div> $results<\/span>++<\/span>;<\/span><\/div> <\/div>
# all done?<\/span><\/div> if<\/span> (<\/span>$results<\/span> ==<\/span> $expected_results<\/span>)<\/span> {<\/span><\/div> exit<\/span>;<\/span><\/div> }<\/span><\/div>}<\/span><\/div> <\/div>
__END__<\/span><\/div><\/pre><\/div>\n \n <\/div>\n\n