concurrent-pump: bulk_queue_reader class has been added