File Coverage

blib/lib/AnyEvent/ProcessPool/Task.pm

Criterion	Covered	Total	%
statement	53	54	98.1
branch	6	8	75.0
condition			n/a
subroutine	18	18	100.0
pod	0	7	0.0
total	77	87	88.5

package AnyEvent::ProcessPool::Task;
# ABSTRACT: A serializable work unit
$AnyEvent::ProcessPool::Task::VERSION = '0.07';
use common::sense;
use Carp;
use Class::Load 'load_class';
use Data::Dump::Streamer;
use MIME::Base64;
use Try::Catch;

use constant READY => 1;
use constant DONE  => 2;
use constant FAIL  => 4;

sub new {
  my ($class, $code, $args) = @_;
  bless [READY, [$code, $args]], $class;
}

sub done   { $_[0][0] & DONE }
sub failed { $_[0][0] & FAIL }

sub result {
  return $_[0][1] if $_[0][0] & DONE;
  return;
}

sub execute {
  my $self = shift;

  try {
    my ($work, $args) = @{$self->[1]};

    if (ref $work eq 'CODE') {
      $self->[1] = $work->(@$args);
      $self->[0] = DONE;
    }
    else {
      my $class = load_class($work);
      $self->[1] = $class->new(@$args)->run;
      $self->[0] = DONE;
    }
  }
  catch {
    $self->[0] = DONE | FAIL;
    $self->[1] = $_;
  };

  return $self->[0] & FAIL ? 0 : 1;
}

sub encode {
  my $self = shift;
  my $data = DumpLex($self)->Purity(1)->Declare(1)->Indent(0)->Out;
  encode_base64($data, '');
}

sub decode {
  my $class = shift;
  my $data  = decode_base64($_[0]);
  my $self  = eval "do{ $data }";
  croak "task decode error: $@" if $@;
  return $self;
}

1;

__END__