recepies/gearman/gearman.pl

#!/usr/bin/perl

use warnings;
use strict;

use Data::Dump qw(dump);
use Getopt::Long;
use Gearman::Worker;

my $host = '10.60.0.244:4730';
my $function = 'test';

GetOptions(
        'host' => \$host,
        'function' => \$function,
) || die $!;


my $worker = Gearman::Worker->new;
$worker->job_servers( $host );
$worker->register_function( $function => sub {
        my $job = $_[0];
        my $arg = $_[0]->arg;
        warn "# job ",dump($job);
});
warn "# worker ",dump($worker);
$worker->work while 1;

=for client

my $client = Gearman::Client->new;
$client->job_servers($host);

# running a single task
my $result_ref = $client->do_task("add", "1+2");
print "1 + 2 = $$result_ref\n";

# waiting on a set of tasks in parallel
my $taskset = $client->new_task_set;
$taskset->add_task( "add" => "1+2", {
        on_complete => sub { ... }
});

$taskset->add_task( "divide" => "5/0", {
        on_fail => sub { print "divide by zero error!\n"; },
});
$taskset->wait;

=cut
1	dpavlin	203	#!/usr/bin/perl
2
3			use warnings;
4			use strict;
5
6			use Data::Dump qw(dump);
7			use Getopt::Long;
8			use Gearman::Worker;
9
10			my $host = '10.60.0.244:4730';
11			my $function = 'test';
12
13			GetOptions(
14			'host' => \$host,
15			'function' => \$function,
16			) \|\| die $!;
17
18
19			my $worker = Gearman::Worker->new;
20			$worker->job_servers( $host );
21			$worker->register_function( $function => sub {
22			my $job = $_[0];
23			my $arg = $_[0]->arg;
24			warn "# job ",dump($job);
25			});
26			warn "# worker ",dump($worker);
27			$worker->work while 1;
28
29			=for client
30
31			my $client = Gearman::Client->new;
32			$client->job_servers($host);
33
34			# running a single task
35			my $result_ref = $client->do_task("add", "1+2");
36			print "1 + 2 = $$result_ref\n";
37
38			# waiting on a set of tasks in parallel
39			my $taskset = $client->new_task_set;
40			$taskset->add_task( "add" => "1+2", {
41			on_complete => sub { ... }
42			});
43
44			$taskset->add_task( "divide" => "5/0", {
45			on_fail => sub { print "divide by zero error!\n"; },
46			});
47			$taskset->wait;
48
49			=cut