File Coverage

blib/lib/Parallel/Simple/Dynamic.pm

Criterion	Covered	Total	%
statement	21	52	40.3
branch	0	16	0.0
condition			n/a
subroutine	7	11	63.6
pod	3	4	75.0
total	31	83	37.3

package Parallel::Simple::Dynamic;

use Class::Std;
use Class::Std::Utils;
use POSIX qw(ceil);
use Parallel::Simple qw( prun );

use version; our $VERSION = qv('0.0.4');

use warnings;
use strict;

{
        my %list_of  		:ATTR( :get   	     :set   	   :default<[]>    :init_arg );
        my %call_back		:ATTR( :get       :set       :default<''>    :init_arg );
        my %num_of_cores	:ATTR( :get    :set    :default<''>    :init_arg );

	sub START {
	        my ($self, $ident, $arg_ref) = @_;
		return;
	}

	sub drun {
		my ( $self, $arg_ref ) = @_;

		my $parts        =  defined $arg_ref->{parts}	     ? $arg_ref->{parts}        : 2;
		my $list         =  defined $arg_ref->{list} 	     ? $arg_ref->{list}   	:[];
		my $call_back	 =  defined $arg_ref->{call_back}    ? $arg_ref->{call_back} 	:'';

		my @partitions = $self->partition( {parts => $parts, list => $list } );

		my ( $pindex, @prun );
		foreach my $partition ( @partitions ) {
		        my $prun = [ $call_back, ++$pindex, @$partition ];
			push @prun, $prun;
			}
		prun( @prun ) or die( Parallel::Simple::errplus() );
	}

	sub partition {
		my ( $self, $arg_ref ) = @_;

		my $parts =  defined $arg_ref->{parts} ? $arg_ref->{parts} : 2;
		my $list  =  defined $arg_ref->{list}  ? $arg_ref->{list}  : [];
		my @results;
		my @segments = $self->calc_segments( {parts => $parts, list_length => scalar( @$list )} );
		for ( my $i = 1; $i <= $parts; $i++ ) {
			my $start   = $segments[$i-1];
			my $end     = $segments[$i] - 1;
			my @segment = @$list[$start..$end];
			push @results, \@segment;
		}
		return @results;
	}

	sub calc_segments {
		my ( $self, $arg_ref ) = @_;

		my $parts        =  defined $arg_ref->{parts}	     ? $arg_ref->{parts}        : 2;
		my $list_length  =  defined $arg_ref->{list_length}  ? $arg_ref->{list_length}  :'';
		my @segments = (0);
		my $width   = $list_length / $parts;
		for ( my $i = 1; $i <= $parts; $i++ ) {
			$segments[$i] = ceil( ($i) * $width );
		}
		return @segments;
	}
}
1; # End of Parallel::Simple::Dynamic
__END__