Python条件变量详解与使用技巧

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

import threading
import queue
<p>class BlockingQueue:
def <strong>init</strong>(self, max_size=10):
self.queue = queue.Queue(max_size)
self.condition = threading.Condition()</p><pre class="brush:python;toolbar:false;">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