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