NAME

Parallel::Async::Chain - task chain manager.

METHODS

my @results = $chain->recv(@args)

Execute tasks on child processes and wait for receive return values.

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

my $chain = $task_add->join($task_sub)->join($task_times);
my ($res_add, $res_sub, $res_times) = $chain->recv(10, 20);
say $res_add->[0];   ##  30
say $res_sub->[0];   ## -10
say $res_times->[0]; ## 200

my @pids = $chain->run(@args)

Execute tasks on child processes.

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

my $chain = $task_add->join($task_sub)->join($task_times);
my @pids = $chain->run(10, 20);

my @pids = $chain->daemonize(@args)

Execute tasks on daemonized processes.

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

my $chain = $task_add->join($task_sub)->join($task_times);
my @pids = $chain->daemonize(10, 20);

$chain->join($task1, ...);

Join multiple tasks, like Parallel::Async::Task#join.

$task->reset;

Reset the execution status of all tasks, like Parallel::Async::Task#reset.

$task->clone;

Clone and reset the execution status of all tasks, like Parallel::Async::Task#clone.

AUTHOR

karupanerura <karupa@cpan.org>