Select Code to Download

 while (my $message = $event->dequeue ) {
        print "IN HERE\n";
        return 1 if $message eq 'STOP';

$self->{queue}->enqueue('STOP');
    
...

#or code to wait for the thread count to change       
}