ya_concurrent_queue_reader