perl mce9.pl

Parent PID 11581
worker 2 (11584) processing chunk 1
worker 1 (11583) processing chunk 2
worker 1 (11583) processing chunk 4
worker 2 (11584) processing chunk 3
^CHello from INT: 11584
Hello from INT: 11581
Hello from END block: 11584
Parent in INT: $VAR1 = bless( {
                 '00 11584' => '1491592596',
                 '01 11583' => '1491592596',
                 '02 11584' => '1491592598',
                 '03 11583' => '1491592598'
               }, 'MCE::Shared::Hash' );


## mce9.pl: caught signal (INT), exiting
Hello from INT: 11583
Hello from END block: 11583

Killed

##</code><code>##

perl mce9.pl

Parent PID 11554
worker 2 (11557) processing chunk 1
worker 1 (11556) processing chunk 2
worker 2 (11557) processing chunk 3
worker 1 (11556) processing chunk 4
worker 1 (11556) processing chunk 6
worker 2 (11557) processing chunk 5
worker 1 (11556) processing chunk 7
Hello from END block: 11557
Hello from END block: 11556
Hello from END block: 11554
Parent in END: $VAR1 = bless( {
                 '00 11557' => '1491592580',
                 '01 11556' => '1491592580',
                 '02 11557' => '1491592582',
                 '03 11556' => '1491592582',
                 '04 11557' => '1491592584',
                 '05 11556' => '1491592584',
                 '06 11556' => '1491592586'
               }, 'MCE::Shared::Hash' );

##</code><code>##

use strict; use warnings; use feature 'say';
use Data::Dumper; ++$Data::Dumper::Sortkeys;
use MCE::Loop;
use MCE::Shared;
$|++;

my $pid = $$; say "Parent PID $pid";
my $hash = MCE::Shared->hash();

$SIG{'INT'} = $SIG{'TERM'} = sub {
    my $signal = shift; $SIG{'INT'} = $SIG{'TERM'} = sub {};
    say "Hello from $signal: $$";
    if ( $$ == $pid ) {
        say 'Parent in INT: ' . Dumper $hash->export;
    }
    MCE::Signal::stop_and_exit('INT');
};

MCE::Loop->init(
    max_workers => 2, chunk_size => 1, user_begin => sub {
        $SIG{'INT'} = sub {
            my $signal = shift;
            say "Hello from $signal: $$";
            MCE->exit(0);
        };
        $SIG{'TERM'} = sub {
            my $signal = shift;
            say "Hello from $signal: $$";
            MCE::Signal::stop_and_exit($signal);
        };
    }
);

mce_loop {
    my ( $mce, $chunk_ref, $chunk_id ) = @_;
    say sprintf 'worker %s (%s) processing chunk %s', MCE->wid, MCE->pid, $chunk_id;
    for ( @{ $chunk_ref } ) {
        $hash->{ sprintf '%.2d %s', $_, $$ } = time;
        sleep 2;
    }
} ( 0 .. 6 );

MCE::Loop->finish;

END {
    say "Hello from END block: $$";
    if ( $$ == $pid ) {
        say 'Parent in END: ' . Dumper $hash->export;
    }
}