#!/usr/bin/env perl
use strict;
use warnings;
use 5.30.0;
use utf8;
use utf8::all;

use Data::Dump 'pp';
use Parallel::ForkManager;

my $pal = new Parallel::ForkManager(6, '/tmp/' );
my @array = (3..56);
my $array_ref = \@array;
my %results;

sub one {
  ### seting up parallel processing for six processors.
  my %data;
  my $data_ref = \%data;
  
  my $sixes = sub {
    my $input = shift;
    my  $leng = int( $input / 6) + 1;
    my %ha;
    foreach (0..5) {
      $ha{"$_"}{'a'} = $_ * $leng;
      $ha{"$_"}{'b'} = ( $_ + 1 ) * $leng - 1;
    }
    $ha{"5"}{'b'} =  $input;    
    return sub {
      my ( $body, $finish) = @_;
      $pal->run_on_finish( sub { &$finish } );
      foreach (0..5) {
	$pal->start and next;
	foreach ( $ha{"$_"}{'a'}..$ha{"$_"}{'b'} ) {
	  &$body;
	}
	$pal->finish(0,  \%results);
      }
      $pal->wait_all_children;
    }
  }; 
  ## I arm (set,prime?) the closure thus:
  $$data_ref{'fork_s'} = $sixes->( $#$array_ref );  
  
  two($data_ref);
}


sub two {
  my $data_ref = shift;
  
  $$data_ref{'fork_s'}->( sub {
			     my $sn = "$_";  ## = number of sentence
			     $results{'SxW'}{"$sn"}++;
			    # say "Results: ".pp(%results);
			   }, sub {
			     my $refe = $_[5];
			     say "Refe2 empty" if !defined $refe;
			     if (defined($refe)) {
			       say "Refe2 " . pp($$refe{'SxW'});
			     }
			   });
}
one()