I use Thread::Queue; to async {$Qin->enqueue($_) while (<>);}; and the child threads loop and block while (my $line = $Qin->dequeue) {...}. I am not familiar with POE or AnyEvent - is there a similar pattern using those modules?