asyncio.Queue不支持优先级，需用asyncio.PriorityQueue；后者是其子类，基于heapq实现，要求put/get时传入(priority, item)元组，数字越小优先级越高。
asyncio.Queue 本身不支持优先级，得换用 asyncio.PriorityQueue
Python 标准库的 asyncio.Queue 是 FIFO（先进先出）队列，没有内置优先级逻辑。真要按优先级消费任务，必须用 asyncio.PriorityQueue —— 它是 asyncio.Queue 的子类，底层基于 heapq，要求你传入可比较的元素（通常是 (priority, item) 元组）。
put() 和 get() 要配合元组结构使用
往 asyncio.PriorityQueue 里塞东西，不能直接 put(item)，得显式构造带优先级的元组。数字越小，优先级越高（和 heapq 一致）。常见错误是忘记包装或传错顺序：
-
await pq.put((5, "low-pri task"))✅ -
await pq.put("task")❌ —— 会报TypeError: ' -
await pq.put(("high", 1))❌ —— 字符串和整数无法比较，且顺序反了
如果业务逻辑中优先级是枚举或字符串，建议提前映射为整数，比如 {"critical": 0, "normal": 10, "debug": 99}。
注意 priority 值相同时的“不稳定排序”
asyncio.PriorityQueue 在优先级相等时，不保证插入顺序（即不是稳定排序）。例如连续 put 两个 (1, "a") 和 (1, "b")，get() 可能先返回 b。若需严格 FIFO 补偿，可以加个自增计数器：
SkillSub Pro - Python 题解与代码注释双功能技能功能概述SkillSub Pro - Python 题解与代码注释双功能技能是一项面向实际任务的技能，主要用于SkillSub Pro 是一个 Python 题解生成与代码注释的 双功能合体技能 ，专为学生、算法学习者和开发者设计；✅ 一个技能，两种用途 ：；核心要点📝 题解模式 ：输入题目/题号，自动生成完整 Python 题解（含详细注释、解题思路、复杂度分析）；💬 注释模式 ：输入 Python 代码，自动添加详细中。它将相关步骤、
立即学习“Python免费学习笔记（深入）”；
import asyncio import itertools <p>counter = itertools.count() pq = asyncio.PriorityQueue()</p><h1>插入时：(priority, count, item)</h1><p>await pq.put((1, next(counter), "task-a")) await pq.put((1, next(counter), "task-b"))
这样相同 priority 下靠 count 保序，但代价是内存多存一个整数、比较开销略增。
别混用 sync 和 async 的优先级队列
有人试图用 queue.PriorityQueue（同步版）配合 asyncio.to_thread 或 loop.run_in_executor 来“曲线救国”，这会引入线程切换开销，且容易因竞态导致 get() 阻塞行为不符合预期。除非你明确需要跨线程调度，否则纯 async 场景务必坚持用 asyncio.PriorityQueue。
真正麻烦的是优先级动态变化——asyncio.PriorityQueue 不支持修改已入队元素的 priority，只能 cancel 任务并重新入队。这点常被忽略，实际做重调度时得自己维护 pending 任务表。
