sub thread_process {
    my $args = shift;
    my @threads;
    my $queue = Thread::Queue->new();
    for my $p ( 1 .. $PARALLEL ) { 
        push @threads, threads->create( sub {
            while( my $file = $queue->dequeue) { 
                process($file, "Thread $p of $PARALLEL");
        }})
    }
    $queue->enqueue( @$args, (undef) x $PARALLEL );
    $_->join for @threads;
    return 1;
}