#!/usr/bin/perl

use warnings;
use strict;

use Parallel::ForkManager;

my $max_forks = 3;

my $fork = new Parallel::ForkManager($max_forks);

my @array = (1..1000);

# on start callback

$fork->run_on_start(
    sub {
            my $pid = shift;
    }
);

# on finish callback

$fork->run_on_finish(
    sub {
        my ($pid, $exit, $ident, $signal, $core) = @_;
        if ($core){
            print "PID $pid core dumped.\n";
        }
    }
);

# forking code


while (@array){

    my @chunk = splice @array, 0, 200;

    $fork->start and next;

    sleep(2);
    db_save(@chunk);

    $fork->finish;

}

sub db_save {
    my @a = @_;
    print "$a[1]\n";
}

$fork->wait_all_children;