lib/CloudStore/Gearman.pm

   1 package CloudStore::Gearman;
   2 use warnings;
   3 use strict;
   4
   5 use Gearman::Client;
   6
   7 use Data::Dump qw(dump);
   8
   9 sub gearman {
  10         my $gearman = Gearman::Client->new;
  11         $gearman->job_servers('127.0.0.1:4730');
  12         return $gearman;
  13 }
  14
  15 sub gearman_do {
  16         my $self = shift @_;
  17         my $func = shift @_;
  18         my $body = join(' ', @_) . "\n";
  19         warn "## gearman_do $func [$body]\n";
  20
  21         my $result = $self->gearman->do_task( $func => $body );
  22         warn "##>> ",dump($result),$/;
  23         return $$result;
  24 }
  25
  26 1;