- or download this
while( my $node = $Qjob->dequeue ) {
if( $node->{canBeSet} ) {
...
$Q->enqueue( $node ); ## push back for next time.
}
}
- or download this
sub killThread{
my $self = shift;
...
my $amtInQ = $queue->pending();
last if $done && $amtInQ == 0;
...
- or download this
sub killThread{
$queue->enqueue( undef );
}
- or download this
while( 1 ) {
my $node = $queue->dequeue;
...
$Q->enqueue( $node ); ## push back for next time.
}
}