Python 实现线程安全队列方法

python中实现线程安全队列最直接可靠的方式是使用queue.queue，它内置锁和条件变量保证put/get等操作原子性，支持fifo/lifo/优先级，具备阻塞、超时及task_done/join同步机制，避免手动加锁list的性能与竞态问题。

Python 中实现线程安全队列最直接、最可靠的方式是使用标准库中的 queue.Queue，它天生支持多线程读写，无需额外加锁。

用 queue.Queue 实现线程安全队列

queue.Queue 是 Python 官方提供的线程安全队列类，底层已通过 threading.Lock 和条件变量（threading.Condition）保证所有操作（put、get、qsize 等）的原子性。它默认是 FIFO（先进先出），也支持 LIFO（栈）和优先级队列。

• 创建队列：from queue import Queue; q = Queue(maxsize=0)（maxsize=0 表示无限制）
• 入队：q.put(item)（阻塞式，默认 block=True；可设 timeout 避免永久等待）
• 出队：q.get()（同样支持 block 和 timeout）
• 标记任务完成：q.task_done() 配合 q.join() 实现生产者-消费者同步

不推荐手动用 list + Lock 实现

虽然可以用 threading.Lock 包裹普通 list 的 append 和 pop(0) 来模拟队列，但存在明显缺陷：

• list.pop(0) 时间复杂度为 O(n)，频繁操作性能差
• 仅加锁不能完全解决竞态：例如 if not q: q.get() 这类检查后执行的逻辑仍可能出错（check-then-act 问题）
• 缺少阻塞、超时、任务追踪等实用功能，需自行实现，易出错

需要自定义行为时的扩展方式

如果必须基于 queue.Queue 做增强（如带统计、日志、自动重试），应在不破坏其线程安全前提下封装：

立即学习“Python免费学习笔记（深入）”；

• 继承 Queue 并重写 put/get 方法，在调用父类方法前后添加逻辑
• 避免在重写中直接操作内部 self._queue（它是 collections.deque，虽线程安全但非公开接口）
• 若需修改底层结构（如换成有界 deque 或支持跳过逻辑），建议用 queue.SimpleQueue（无阻塞/超时，轻量）或彻底自研并严格测试锁粒度

注意 queue.Queue 的常见陷阱

即使使用官方队列，也需留意几个实际易错点：

• qsize() 返回的是近似值，不保证实时准确，**不可用于条件判断**（如 while q.qsize() > 0:）
• empty() 和 full() 同样是瞬时快照，仅作参考，不能替代阻塞操作
• 消费者必须调用 task_done()，否则 join() 将永远等待
• 异常未捕获时，可能导致队列卡死或任务丢失，建议在 get 后加 try/except