use strict;
use warnings 'all';

sub sfork($&) {
  my($max, $code)= @_;

  foreach my $c (1..$max) {
    wait unless $c<=$max;
    die "Cannot fork: $!\n" unless defined(my $pid= fork);
    exit $code->($c) unless $pid;
  }
  1 until -1 == wait;
}

sfork 2, sub {
  sub getFromProducer {
    use IO::Socket::INET;

    my($socket, $data);
    $socket= new IO::Socket::INET (
      PeerHost=> '127.0.0.1',
      PeerPort=> '5000',
      Proto=> 'tcp'
    ) or die "ERROR in Socket creation: $!\n";
    $socket->autoflush(1);
    $data= <$socket>;
    chomp($data);
    $socket->close();
    return $data;
  }

  while(my $data= &getFromProducer) {
    print "($$) Got $data from producer.\n";
  }
}