PROCESS_DATA:
while(1){

    if( scalar @ready > 0 ){

         if( my $data = shift @to_be_processed ){
            my $t = shift(@ready);
            $shash{$t}{'data'} = $data;
            $shash{$t}{'go'} = 1; 
            print "thread $t restarting\n";
          }else{ print "out of input\n"; last PROCESS_DATA;  }
     }
} # end PROCESS_DATA

##</code><code>##

sub worker{
    my $thr_num = shift;
    print "$thr_num started\n"; 
    my $count;


    while(1) {

        WORKER_LOOP:
        while(1){

            if( $shash{$thr_num}{'die'} ){
            print "thread $thr_num finishing\n"; 
            return} 
            #wait for $go_control  
            if($shash{$thr_num}{'go'}){      

            if($shash{$thr_num}{'die'}){
            print "thread finishing\n"; 
            return} 

            $count++;            
            my $str = '    'x$thr_num; #printout spacer
            print $str.$thr_num.'->'.$count.$shash{$thr_num}{'data'},"\n";

            if ($count > 10){ last WORKER_LOOP; }

            #select(undef,undef,undef,.25);
            sleep rand 5

            }else{ 
                $count = 0;
                select(undef,undef,undef,.25); 
            }# sleep until awakened 

        } #end WORKER_LOOP


        # Recycle Thread
        $shash{$thr_num}{'go'} = 0;
        print "$thr_num done....going back to sleep\n";
        $shash{$thr_num}{'data'} = '';
        $count = 0;
        push @ready, $thr_num;
        print "pushing $thr_num\n";
    }

    return;
}