NAME

AnyEvent::Gearman::WorkerPool - Managing Worker's lifecycle with Slots

VERSION

version 1.0

SYNOPSIS

worker_pool.pl

    #!/usr/bin/env perl

    use AnyEvent;
    use AnyEvent::Gearman::WorkerPool;
    
    my $cv = AE::cv;

    my $sig = AE::signal 'INT'=> sub{ 
            DEBUG "TERM!!";
            $cv->send;
    };

    my $pool = AnyEvent::Gearman::WorkerPool->new(
            config=>
            {   
                    global=>{ # common config
                            job_servers=>['localhost'], # gearmand servers
                            libs=>['./lib'], # perl5 library paths
                            max=>3, # max workers
                            },  
                    slots=>{
                            'TestWorker'=>{ # module package name which extends AnyEvent::Gearman::WorkerPool::Worker.
                                    min=>20, # min workers, count when started.
                                    max=>50, # overrides global config's max. Workers will extend when all workers are busy.
                                    workleft=>10, # workleft is life of worker. A worker will be respawned after used 10 times. 
                                                            # if workleft is set as 0, a worker will be never respawned.
                                                            # this feature is useful if worker code may has some memory leaks.
                            },
                            # you can place more worker modules here.
                    }   
            }   
    );

    $pool->start();

    my $res = $cv->recv;
    undef($tt);
    $pool->stop;
    undef($pool);

lib/TestWorker.pm

    package TestWorker;
    use Log::Log4perl qw(:easy);
    Log::Log4perl->easy_init($DEBUG);

    use Moose;

    extends 'AnyEvent::Gearman::WorkerPool::Worker';

    sub slowreverse{
    DEBUG 'slowreverse';
    my $self = shift;
    my $job = shift;
    my t = AE::timer 1,0, sub{
        my $res = reverse($job->workload);
        $job->complete( $res );
    };
}
sub reverse{
    DEBUG 'reverse';
    my $self = shift;
    my $job = shift;
    my $res = reverse($job->workload);
    DEBUG $res;
    $job->complete( $res );
}
sub _private{
    my $self = shift;
    my $job = shift;
    DEBUG "_private:".$job->workload;
    $job->complete();
}

    1;

client.pl

    #!/usr/bin/env perl
    use AnyEvent;
    use AnyEvent::Gearman;
    my $cv = AE::cv;
    my $c = gearman_client 'localhost';
    $c->add_task(
            'TestWorker::reverse' => 'HELLO WORLD', # 'MODULE_NAME::EXPORTED_METHOD' => PAYLOAD
            on_complete=>sub{
                    my $reversed = $_[1];
                    $cv->send( $reversed );
            },
    );

    my $reversed = $cv->recv;

    print $reversed."\n"; # 'DLROW OLLEH'

AUTHOR

HyeonSeung Kim sng2nara@hanmail.net

COPYRIGHT AND LICENSE

This software is copyright (c) 2012 by HyeonSeung Kim.

This is free software; you can redistribute it and/or modify it under the same terms as the Perl 5 programming language system itself.