Python队列达最大容量后输出停滞且程序无法终止问题求助

问题原因 #

1. 当Queue达到maxsize=10时，子线程的queue.put(i)会阻塞，必须等主线程取出元素腾出空间才能继续放入下一个。
2. 主线程的循环条件while not queue.empty()存在逻辑漏洞：取完前10个元素后，队列短暂为空，循环直接退出，但此时子线程还卡在put()的阻塞状态，根本没机会放入剩下的90个元素。
3. 子线程一直处于运行状态，导致程序无法自行终止；强制终止时，Python的线程清理机制会抛出KeyboardInterrupt异常。

修复方案 #

方案1：使用结束标记 #

在子线程完成所有元素放入后，向队列中放入一个特殊标记（比如None），主线程取到该标记时停止循环：

from queue import Queue
from threading import Thread

def fetch(queue):
    for i in range(100):
        queue.put(i)
    queue.put(None)  # 添加结束标记

def main():
    queue = Queue(maxsize=10)
    t = Thread(target=fetch, args=(queue,))
    t.start()

    while True:
        item = queue.get()  # 阻塞等待元素，无需检查队列是否为空
        if item is None:
            break
        print(item)
    t.join()  # 等待子线程完全结束

方案2：结合子线程状态与队列状态 #

主线程循环判断：只要子线程还在运行，或者队列中还有元素，就继续处理；队列为空时短暂等待，避免CPU空转：

from queue import Queue
from threading import Thread
import time

def fetch(queue):
    for i in range(100):
        queue.put(i)

def main():
    queue = Queue(maxsize=10)
    t = Thread(target=fetch, args=(queue,))
    t.start()

    while t.is_alive() or not queue.empty():
        # 批量取出当前队列中的所有元素
        while not queue.empty():
            item = queue.get()
            print(item)
        time.sleep(0.1)  # 短暂等待子线程放入新元素
    t.join()

关键说明 #

• queue.get()默认是阻塞式调用，会一直等待直到队列中有元素可取，这比主动检查queue.empty()更可靠。
• 必须等待子线程完全结束（调用t.join()），确保程序能正常终止，避免残留线程导致的异常。

内容的提问来源于stack exchange，提问作者Luke Wardford