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.