concurrent-pump: added bulk_queue_reader class