view release on metacpan or  search on metacpan

lib/AnyEvent/ProcessPool/Process.pm  view on Meta::CPAN

  });
}

sub run {
  my ($self, $task) = @_;
  $self->await;

  my $cv = AE::cv;
  push @{$self->{pending}}, $cv;

  $self->{ps}->say($task->encode);
  --$self->{ps}->user->{reqs} if $self->{limit};

  return $cv;
}

1;

__END__

=pod

lib/AnyEvent/ProcessPool/Worker.pm  view on Meta::CPAN

$AnyEvent::ProcessPool::Worker::VERSION = '0.07';
use v5.10;
use common::sense;
use AnyEvent::ProcessPool::Task;

sub run {
  local $| = 1;
  while (defined(my $line = <STDIN>)) {
    my $task = AnyEvent::ProcessPool::Task->decode($line);
    $task->execute;
    say $task->encode;
  }
}

1;

__END__

=pod

=encoding UTF-8