segment, task: support plan | consume_n(queue_front<T>) construct