concurrent-pump: concurrent_pump class has been changed to ensure thread-safe execution
concurrent-pump: bulk_queue_reader class has been added