my $q = Thread::Queue->new(); my $pq = Thread::Queue->new(); my @threads = map { threads->create( \&worker, $_ ) } ( 1 .. $config->{number_of_threads} ); push @threads, threads->create( \&controller ); my $mech = WWW::Mechanize->new(); $mech->agent_alias("Windows IE 6"); $mech->get( $config->{start_url} ); my @states = find_states($mech); foreach my $state (@states) { process_state($state); } while ( $q->pending() ) { sleep 1; } foreach ( 1 .. $config->{number_of_threads} ) { $q->enqueue(undef); } while ( $pq->pending() ) { sleep 1; } $pq->enqueue(undef); foreach my $thr (@threads) { if ( $thr->is_joinable() ) { $thr->join(); } } #### while ( my $org = $q->dequeue() ) { parse_org( $org, $mech ); $pq->enqueue($org); }