IPC::Msg as a fork safe queue. Couple caveats that make it less cool, the by-default maximum queue size seems to be very small. Configurable though by changing /proc/sys/kernel/msgmnb which is the max size in bytes of an individual queue up to 2^31 - 1 on my system at least. Check with  ipcs -l. You also have to delete the queue when finished. Or not if you want to use it later. You can also find the same queue in different scripts with ftok, not shown. You can also see queue sizes / number of messages with ipcs command, add flags to pull off different messages from the queue. You don't always have to do FIFO, you can add different kinds of messages to the same queue, and you can block or not block if you want to have multiple queues being worked at the same time.

For complex data structures you would need to serialize or pack / unpack which other cpan modules may already address and better. Message queues are already documented in perlipc, but a little sugar show show versatile it can be. Basically add or remove from the queue with any child process not worrying about blocking / synchronization issues, but you can accidentally destroy the queue before it is empty, or leave an empty or not-empty queue hanging around that you would have to delete with icprm command. 

#!/usr/bin/env perl
use strict;
use warnings;
use feature 'say';
use IPC::SysV qw/IPC_PRIVATE S_IRUSR S_IWUSR IPC_NOWAIT/;
use IPC::Msg;
$|++;

use constant MSG_BYTES => 1024;

my $q = IPC::Msg->new(IPC_PRIVATE,S_IRUSR|S_IWUSR);

sub quit { $q->remove; }
$SIG{INT} = \&quit;

sub enqueue {
    my $msg = shift;
    my $msg_type = shift // 1; # Used for message selection, see msgsn
+d(2)
    $q->snd($msg_type,$msg,IPC_NOWAIT) || die $!;
}

sub dequeue {
    my $type = shift // 1; # See msgop(2)
    my $msg;
    $q->rcv($msg,MSG_BYTES,$type,IPC_NOWAIT);
    #if ($!) { warn "$$ - $!" }
    return $msg // undef;
}

sub dequeue_block {
    my $msg;
    my $type = shift // 1; # See msgop(2)
    $q->rcv($msg,MSG_BYTES,$type);
    #if ($!) { warn "$$ - $!" }
    return $msg // undef;
}

sub isEmpty {
    my $stat = $q->stat;
    return $stat->qnum == 0;
}

sub isPrime {
    my $num = shift;
    return 1 if ($num < 4);
    return 0 if ($num %2 == 0);
    for (my $i=3; $i <= sqrt($num); $i+=2) {
        return 0 if $num % $i == 0;
    }
    return 1;
}

my $n_workers = shift // die ;

enqueue($_) for (1..2_000_000);

my $parent = $$;

for (my $i=1; $i<$n_workers && $$ == $parent; $i++) {
    fork // die;
}

while (my $data = dequeue()) {
    if (isPrime($data)) {
        print "Prime: $data\n";
    }
}

END {
    if ($$ == $parent) {
       1 until wait == -1;
       quit;
    }
}

[download]

Update 2019-02-04 - You can't wait on grandchildren, changed code to only fork from parent. Fixed spelling of empty.

In reply to IPC::Msg Fork queue by trippledubs

Title:
Use:  <p> text here (a paragraph) </p>
and:  <code> code here </code>
to format your post, it's "PerlMonks-approved HTML":


  • Posts are HTML formatted. Put <p> </p> tags around your paragraphs. Put <code> </code> tags around your code and data!
  • Titles consisting of a single word are discouraged, and in most cases are disallowed outright.
  • Read Where should I post X? if you're not absolutely sure you're posting in the right place.
  • Please read these before you post! —
  • Posts may use any of the Perl Monks Approved HTML tags:
    a, abbr, b, big, blockquote, br, caption, center, col, colgroup, dd, del, details, div, dl, dt, em, font, h1, h2, h3, h4, h5, h6, hr, i, ins, li, ol, p, pre, readmore, small, span, spoiler, strike, strong, sub, summary, sup, table, tbody, td, tfoot, th, thead, tr, tt, u, ul, wbr
  • You may need to use entities for some characters, as follows. (Exception: Within code tags, you can put the characters literally.)
            For:     Use:
    & &amp;
    < &lt;
    > &gt;
    [ &#91;
    ] &#93;
  • Link using PerlMonks shortcuts! What shortcuts can I use for linking?
  • See Writeup Formatting Tips and other pages linked from there for more info.