I am trying to process data using a set of threads and insert them into a queue by others, currently the process of queuing and deleting the queue does not seem to work
Anyway ???
sub process() {
while (my @DataElement = $DataQueue->dequeue()) {
print "\t".$DataElement[0]."\n";
}
}
I use the following to put data
my @l;
push(@l, $directories.$suffix);
push(@l, "testclass");
push(@l, $eachFile);
$DataQueue->enqueue(\@l);
source
share