File Coverage

blib/lib/Parallel/parallel_map.pm

Criterion	Covered	Total	%
statement	19	19	100.0
branch	4	4	100.0
condition			n/a
subroutine	6	6	100.0
pod	0	1	0.0
total	29	30	96.6

package Parallel::parallel_map;

use 5.008;
our $VERSION = '0.03';

use strict;
use warnings;
use Parallel::DataPipe;

require Exporter;

our @ISA = qw(Exporter);

our @EXPORT = qw(parallel_map);

our $INIT_DATA_PROCESSOR; # has to be code ref

sub parallel_map(&@) {
    my ($code,@input) = @_;
    my (@result,@output);
    if (wantarray) {
        @output = (output=>sub {my ($r,$i) = @_;$result[$i] = $r;});
    }
    Parallel::DataPipe::run {
        input => \@input,
        process => $code,
        init_data_processor => $INIT_DATA_PROCESSOR, # this behaviour is introduced at 0.03
        @output,
    };
    return wantarray?@result:();
}

1;

__END__