Python并发编程-生产消费模型
Posted 空林~~清风~~~
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Python并发编程-生产消费模型相关的知识,希望对你有一定的参考价值。
生产消费模型初步
#产生两个子进程,Queue可以在子进程之间传递消息
from multiprocessing import Queue,Process
import random
import time
#队列是进程安全的,队列里的数据只能被一个进程获取,所有q.put(None)只对应一个进程,所以要放两个q.put(None)
def producer(name, food, q):
for i in range(10):
time.sleep(random.randint(1,3))
f = ('%s生产了%s%s' %(name,food,i))
print(f)
q.put(f)
def consume(q,name):
while True:
food = q.get()
if food is None:
print('%s获取了个一个空'%name)
break
print('