import threading
import time
condition = threading.Condition()
data_ready = False
def consumer():
print("消费者：等待数据准备...")
with condition:
while not data_ready:
condition.wait()
print("消费者：数据已就绪，开始处理")
def producer():
global data_ready
print("生产者：开始生成数据")
time.sleep(2)
with condition:
data_ready = True
print("生产者：数据准备完成，通知等待线程")
condition.notify()
创建线程
t1 = threading.Thread(target=consumer)
t2 = threading.Thread(target=producer)
t1.start()
t2.start()
t1.join()
t2.join()

import threading
import queue
class BlockingQueue:
def init(self, max_size=10):
self.queue = queue.Queue(max_size)
self.condition = threading.Condition()
def put(self, item):
    with self.condition:
        while self.queue.qsize() >= self.queue.maxsize:
            self.condition.wait()
        self.queue.put(item)
        self.condition.notify_all()

def get(self):
    with self.condition:
        while self.queue.empty():
            self.condition.wait()
        item = self.queue.get()
        self.condition.notify_all()
        return item