Python 通过队列实现一个生产者消费者模型

时间:2023-03-09 13:07:42
Python 通过队列实现一个生产者消费者模型
import time
from multiprocessing import Process,Queue #生产者
def producer(q):
for i in range(10):
time.sleep(0.7)
s = '大包子%s号'%i
print(s+'新鲜出炉,拿去用')
q.put(s) def consumer(q):
while 1:
time.sleep(1) baozi = q.get()
print(baozi+'被吃了') if __name__ == '__main__':
q = Queue(10) pro_p = Process(target=producer,args=(q,))
con_p = Process(target=consumer,args=(q,))
pro_p.start()
con_p.start()