in reply to Re^2: problem in queue implementation
in thread problem in queue implementation
Did you want each row to be a different queue item?
while (my $row = $sth->fetch()) { # Must copy since fetch reuses array. $row = [ @$row ]; $q->enqueue(share($row)); }
You will be using threads right? Otherwise a queue is simply:
my @queue; # Put stuff in while (...) { push @queue, ...; } # Take stuff out while (@queue) { my $item = shift(@queue); ... }
|
|---|