Condition是Python中的条件变量,它可以让线程在某些条件下等待、通知和唤醒其他线程。Condition由Lock和Condition变量两部分组成。当调用Condition的wait()方法时,线程会释放锁并进入等待状态,当其他线程调用Condition的notify()或notifyAll()方法时,等待的线程将被唤醒并重新尝试获取锁下面的示例展示了如何使用Condition来实现生产者-消费者模型:
import threading
import queue
class Producer(threading.Thread):
def __init__(self, queue, condition):
threading.Thread.__init__(self)
self.queue = queue
self.condition = condition
def run(self):
while True:
with self.condition:
if self.queue.qsize() < 10:
self.queue.put(1)
print("Produced 1 item")
self.condition.notify()
else:
self.condition.wait()
class Consumer(threading.Thread):
def __init__(self, queue, condition):
threading.Thread.__init__(self)
self.queue = queue
self.condition = condition
def run(self):
while True:
with self.condition:
if self.queue.qsize() > 0:
self.queue.get()
print("Consumed 1 item")
self.condition.notify()
else:
self.condition.wait()
if __name__ == '__main__':
queue = queue.Queue()
condition = threading.Condition()
producer = Producer(queue, condition)
consumer = Consumer(queue, condition)
producer.start()
consumer.start()
producer.join()
consumer.join()
在上面的示例中,我们使用了一个Queue来作为生产者和消费者之间的共享数据结构,并使用了一个Condition来协调它们之间的交互。生产者会不断往队列中添加元素,当队列已经满时,它会等待消费者消费一些元素后再继续添加。消费者会不断从队列中取出元素,当队列为空时,它会等待生产者添加元素后再继续取出。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。