队列、生产消费模型.html

标签：

import queue

import time 

q = queue.Queue(20) # 创建个先进先出队列

 

# “生产者” 每个厨师都一直创建包子，直到队列满了阻塞，

def productor(arg):

while True:

q.put(str(arg)+‘:包子‘)   # 创建一个包子放入队列，厨师编号:包子

 

# “消费者” 每个顾客都一直消费包子，直到队列空了阻塞

def consumer(arg):

while True:

print(arg, q.get())  # 从队列拿出一个包子， 哪个厨师:包子

time.sleep(2)

for i in range(3): # 创建3个厨师

t = threading.Thread(target=productor, args=(i,))

t.start()

for j in range(20): # 创建20个人

t = threading.Thread(target=consumer, args=(,))

t.start()

队列、生产消费模型.html

标签：

原文地址：http://www.cnblogs.com/qiaogy/p/5875442.html