__author__ = "JentZhang"
import time, threading, queue
q = queue.Queue(maxsize=) # 声明队列
def Producer(name):
'''生产者'''
count =
while True:
q.put(count) # 往队列中添加数据
print("[%s] 生产了第%s包子\n" % (name, count))
count +=
time.sleep()
def Consumer(name):
'''消费者'''
while True:
i = q.get() # 从队列中取数据
print("====[%s] 吃了第%s个包子\n" % (name, i))
time.sleep()
'''设置多线程'''
p = threading.Thread(target=Producer, args=("Jent",))
c1 = threading.Thread(target=Consumer, args=("张三",))
c2 = threading.Thread(target=Consumer, args=("李四",))
'''线程开启'''
p.start()
c1.start()
c2.start()