主函数

if name == "main": # 创建一个队列 queue = Queue() # 创建一个事件 event = Event() # 创建一个生产者线程 p = Thread(target=producer) # 创建一个消费者线程 c = Thread(target=consumer) # 启动生产者线程 p.start() # 启动消费者线程 c.start() # 等待生产者线程结束 p.join() # 等待消费者线程结束 c.join()

# 生产者函数def producer for i in range1000 # 往队列中放入数据 queueputi if i 10 == 9 # 通知消费者线程进行消费 eventset # 等待消费者线程消费完数据 eventwait # 生产完数据

原文地址: http://www.cveoy.top/t/topic/h72y 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录