#!/usr/bin/env perl

use strict;
use warnings;
use MCE::Hobo;
use feature qw(say);
use constant AMOUNT => 0.001;

my $cores = MCE::Util::get_ncpu();

MCE::Hobo->init(
    max_workers => $cores,
    void_context => 1,
    posix_exit => 1,
);

sub consumer_task {
    my $id = shift;
    say qq($id ) . MCE::Hobo->pid();
    qx( sleep @{[ AMOUNT ]} ); 
}

for my $id ( 1..800 ) {
    my $hobo = MCE::Hobo->create( \&consumer_task, $id );
}

MCE::Hobo->wait_all();

##</code><code>##

#!/usr/bin/env perl

use strict;
use warnings;
use MCE::Hobo;
use MCE::Channel;
use feature qw(say);
use constant AMOUNT => 0.001;

my $cores = MCE::Util::get_ncpu();
my $queue = MCE::Channel->new();

MCE::Hobo->init(
    void_context => 1,
    posix_exit => 1,
);

# Consumers

sub consumer_task {
    while ( my $input = $queue->dequeue() ) {
        say qq($input->{id} ) . MCE::Hobo->pid();
        qx( sleep @{[ AMOUNT ]};) 
    }
}

MCE::Hobo->create( \&consumer_task ) for 1..$cores;

# Producer

for ( 1..800 ) {
    $queue->enqueue({ id => $_ });
}

$queue->end();

MCE::Hobo->wait_all();