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); ... }
In reply to Re^3: problem in queue implementation
by ikegami
in thread problem in queue implementation
by rajj.nmt4
| For: | Use: | ||
| & | & | ||
| < | < | ||
| > | > | ||
| [ | [ | ||
| ] | ] |