use strict;
use warnings;

use Proc::Fork;
use IO::Pipe;
use IO::Select;

my $kids = 4;    # How many children we'll create
$SIG{CHLD} = 'IGNORE';
my $sel = new IO::Select();

my @payloadlist;

for (my $i=0; $i<@ARGV; $i++)
{
	my $idx = $i % $kids;
	push @{$payloadlist[$idx]}, $ARGV[$i];
}

my $start = localtime();
print "Started $start $$\n";

foreach my $payload (@payloadlist) {
	my $pipe = new IO::Pipe;

	child {
		my $p = $pipe->writer;
		foreach my $filename (@{$payload})
		{
			my $outFile = toTSV($filename);
			my $now = localtime();
			print "$$ $now - Completed $filename\n";

			print $p $outFile."\n";
		}
		exit;
	};

	my $r = $pipe->reader;
	$sel->add($r);
}

my $workdone = 0 ;
while ( $workdone < @payloadlist )
{
	while(my @ready = $sel->can_read) 
	{
		foreach my $fh (@ready) 
		{
                        while (<$fh>) 
                        { 
                                chomp $_; 
                                system("echo importing $_\n"); 
                                unlink $_; 
                                $workdone++;
                        }
			$sel->remove($fh);
			$fh->close;
		}
	}
}

my $end = localtime();
print "Completed $end\n";

sub convert{ $_[0]; }

sub toTSV {
	my $filename = shift;
	my $outFile = $filename . '.tsv';
	open my $fhIn, '<', $filename or warn "$filename : $!" and next;
	open my $fhOut, '>', $outFile or warn "$outFile : $!"  and next;

	while( <$fhIn> ) {
		my $tsv = convert( $_ );
		print $fhOut $tsv;
	}
	close $fhOut;
	close $fhIn;

	return $outFile;
}