Python多线程问题

我是Python新手,在使用队列的多线程Python应用程序中,我偶尔会遇到停滞问题。用于管理生产者线程和消费者线程之间任务的队列。有时,应用程序会停止响应。当有新项目添加到队列中时,生产者会通知消费者,而消费者会等到收到此通知后再访问该项目。

这是我的代码的简化版本:

import threading
import queue

q = queue.Queue()

def producer():
    for i in range(5):
        item = f"item-{i}"
        q.put(item)
        print(f"Produced {item}")
        with condition:
            condition.notify_all()

def consumer():
    while True:
        with condition:
            condition.wait()
        item = q.get()
        print(f"Consumed {item}")
        if item is None:
            break

condition = threading.Condition()

prod_thread = threading.Thread(target=producer)
cons_thread = threading.Thread(target=consumer)

prod_thread.start()
cons_thread.start()

prod_thread.join()
q.put(None)
cons_thread.join()

是什么导致了这个问题?