多线程下调用单例对象封装的Queue队列is_empty方法程序卡住问题咨询

• 无休眠忙等抢占CPU资源，阻塞生产者执行
  你写的while True循环在队列判定为空时直接continue进入下一轮判断，属于无任何等待的忙等逻辑，会占满当前CPU核心的算力。CPython的全局解释器锁（GIL）调度机制下，这类CPU密集型的死循环会长期抢占GIL，导致负责往队列写入消息的生产者线程拿不到执行权限，永远无法往队列中存入数据，最终程序就卡在这个空转循环中。
• 状态判断与后续操作存在竞态条件，引发隐性阻塞
  is_empty()仅返回调用瞬间的队列状态，完全可能出现刚判定队列非空，还没执行后续操作的间隙，队列就被其他消费者线程取空的情况。如果你后续执行get_msg()时调用的是queue.Queue.get()默认的阻塞逻辑，此时就会直接阻塞，整个线程停止运行。
• 单例实现不严谨导致队列实例不统一
  当前单例没有禁止外部直接调用构造方法MySingleton()，如果生产者线程是直接实例化MySingleton()后写入消息，而消费者通过get_instance()获取实例读取，双方操作的是两个完全独立的队列，消费者的队列永远为空，就会一直死循环。
• 生产者端阻塞导致无数据写入
  当队列满时，queue.Queue.put()默认是阻塞状态，如果生产者写入速度远快于消费者消费速度，队列达到10000的上限后生产者就会卡住，再也无法写入新消息，消费者自然也读不到数据。

1. 优先替换自定义空判断逻辑，直接用队列自带的阻塞取数能力，不需要额外判断空：

while True:
    msg = MySingleton.get_instance().get_msg()
    # 直接处理消息即可，get()会自动阻塞等待直到有新消息

2. 如果必须保留空判断逻辑，给忙等加短休眠让出CPU：

import time
while True:
    if MySingleton.get_instance().is_empty():
        time.sleep(0.01)
        continue
    # 后续操作

3. 补全单例逻辑，禁止外部直接实例化，在__init__方法中加判断即可：

def __init__(self):
    if MySingleton.__instance is not None:
        raise Exception("该类是单例，请用get_instance()获取实例")
    self.__msg_queue = queue.Queue(maxsize=self.MAX_QUEUE_SIZE)

4. 如果需要避免生产者阻塞，可给put操作加超时或者设置非阻塞参数。

内容的提问来源于stack exchange，提问作者Aviv Yehezkel