#!/usr/bin/perl
use strict;
use warnings;
use diagnostics;
use Parallel::ForkManager;

my $config;
$config->{max_prozesse} = 1000;
$config->{poll_interval} = 1;

my $forkmanager = Parallel::ForkManager->new($config->{max_prozesse});
$forkmanager->run_on_start(
	sub {
		my ($pid,$file) = @_;
		print "Sohn '$pid' startet mit Datei '$file'\n";
	},
);
$forkmanager->run_on_finish(
	sub {
		my ($pid) = @_;
		print "Sohn '$pid' ist beendet\n";
	},
);
$forkmanager->run_on_wait(
	sub {
		print "Warte auf Aufträge\n"
	},
	$config->{poll_interval},
);
my $lauf = 1;
while ($lauf) {
	if (opendir my $vh,'.') {
		foreach my $file (
			grep {
				$_ =~ /^[a-z0-9]+\-auftrag.dat$/
					&&
				!-z $_
			}
			readdir $vh
		) {
			print "Datei $file gefunden\n";
			rename($file,"$file-erl");
			my $pid = $forkmanager->start($file) and next;
			# Sohn
			print "Hier meldet sich Sohn '$pid' von der Front\n";
			$forkmanager->finish();
		}
	}
}
$forkmanager->wait_all_children;