NAME

Parallel::Async::Task - task class for Parallel::Async.

METHODS

$task = Parallel::Async::Task->new(\%args)

Creates a new Parallel::Async::Task instance.

use Parallel::Async::Task;

# create new task
my $task = Parallel::Async::Task->new(code => sub {
    my $result = ...; ## do some task
    return $result;
});

this code is same as

use Parallel::Async;

# create new task
my $task = async {
    my $result = ...; ## do some task
    return $result;
};

Arguments can be:

• code

  CodeRef to run on child process. This CodeRef can get arguments from recv or as_anyevent_child or run method arguments.

my @result = $task->recv(@args)

Execute task on child process and wait for receive return value.

# create new task
my $task = async {
    my ($x, $y) = @_;
    return $x + $y;
};

my $res = $task->recv(10, 20);
say $res; # 30

my $watcher = $task->as_anyevent_child(@args)

Execute task on child process and receive return value with AnyEvent->child. This feature required AnyEvent.

# create new task
my $task = async {
    my ($x, $y) = @_;
    return $x + $y;
};

my $watcher; $watcher = $task->as_anyevent_child(sub {
    my ($pid, $status, $res) = @_;
    say $res; ## 30
    undef $watcher;
}, 10, 20);

my $pid = $task->run(@args)

Execute task on child process.

# create new task
my $task = async {
    my ($url) = @_;
    post($url);
};

my $pid = $task->run($url);
wait;

my $pid = $task->daemonize(@args)

Execute task on daemonized process.

# create new task
my $task = async {
    my ($url) = @_;
    post($url);
};

my $pid = $task->daemonize($url);

my $chain = $task->join($task1, ...);

Join multiple tasks. Can be execute tasks in parallel by chained task. See also Parallel::Async::Chain for more usage.

$task->reset;

Reset the execution status of the task. This feature is useful when you want to re-execute the same task.

# create new task
my $task = async {
    my ($x, $y) = @_;
    return $x + $y;
};

my $res = $task->recv(10, 20);
say $res; # 30

$res = $task->reset->recv(10, 30);
say $res; # 40

$task->clone;

Clone and reset the execution status of the task. This feature is useful when you want to execute same tasks in parallel.

# create new task
my $task = async {
    my ($x, $y) = @_;
    return $x + $y;
};

my @res = $task->join(map { $task->clone } 1..9)->recv(10, 30);

AUTHOR

karupanerura <karupa@cpan.org>