RocketMQ中的优先级队列是怎样实现的？是否有开源计划？

[Silencesk]

1. 你好，近期在这篇文章【全新 AI 消息模型：Apache RocketMQ 如何让 AI 应用拥抱事件驱动架构？】中看到，阿里内部RocketMQ有优先级队列这一能力，支持抢占式分配与按权重分配
2. 能否简单透露下优先级队列的实现逻辑？该功能是否会考虑开源？

[hill007299]

优先级队列基于Pop消费模式实现的，预计S1开源。