#!/opt/perl-5.8.8/bin/perl -w
#
#


use strict;
use Getopt::Long;
use threads;
use threads::shared;
use Thread::Queue;

require Data::Dumper;



my $max_thread_count = 10;

my $version = "0.1_01";


my @stores = sort map { sprintf 'store%03d', $_ } 0..$max_thread_count;

my $thread;
my $thread_list;
my $tid;

sub writeLog {
   print "$_[0]\n";
}

my $jobs = Thread::Queue->new(@stores);

# read work file
sub processWF {
   my @lines = (
      'perl -wle "print q(storeplaceholder stage 1);sleep(rand(10));print q(storeplaceholder stage 1 done)"',
      'perl -wle "print q(storeplaceholder stage 2);sleep(rand(10));print q(storeplaceholder stage 2 done)"',
   );

   while (defined (my $item = $jobs->dequeue)) {
      writeLog("Launching $item");
      foreach my $line (@lines) {
            print "replacing $line with $item\n";
            $line =~ s/storeplaceholder/$item/g;
            #print "running: $line\n";
            system($line) == 0
                or warn "Couldn't launch $line: $!";
      }
   }
}


$jobs->enqueue(undef) for 1..$max_thread_count;

my @workers = map { threads->create( \&processWF ) } 1..$max_thread_count;


$_->join() for @workers;