#!/usr/bin/perl -- use strict; use warnings; use threads stack_size => 4096; use Thread::Queue; my %serverQ; my $resultQ = Thread::Queue->new; my @workers = map { my $workQ = Thread::Queue->new; threads->create( \&Worker, $workQ, $resultQ ); } 1..10; ... while( @targets ){ ... if( my $q = $serverQ{ $host } ){ $q->enqueue( [ ## 'Foo::bar::deployRoutine', $onearg, $twoarg, $threearg , 'deployRoutine' => $targetServer, $deploySource, $deployDest, "true", ] ); ... FreeFreeWorkers( \%serverQ ); ## check empty Qs, unassociate from a host ... $_->join for threads->list; exit( 0 ); sub Worker { my( $workQ, $resultQ ) = @_; while( defined( my $jobDesc = $workQ->dequeue ) ) { my( $package, $function, @args ) = @$jobDesc; require Module::Load; Module::Load::load( $package ); $resultQ->enqueue( [ $function->( @args ) ] ); } return; }