client-anyevent.pl

use strict;
use warnings;

use AnyEvent;
use AnyEvent::Gearman::Client;

my $count = shift || 1000;

my $client = AnyEvent::Gearman::Client->new(job_servers => ['127.0.0.1:7003']);

my $cv = AnyEvent->condvar;
my $done = 0;

sub done {
    $cv->send if ++$done > $count;
    new();
}

sub new {
    $client->add_task(
        test => 1 =>
        on_complete => \&done,
        on_error => \&done,
    );
}

new();

$cv->recv;