# -*- coding: UTF-8 -*-
import queue,threading,time
q = queue.Queue(maxsize=10)
def Producer(name): #生产者函数
    count = 1
    while True:
        q.put("骨头%s"%count)
        print("生产了%s个骨头"%count)
        count += 1
        time.sleep(1)
def Consumer(name):
    while True:
        while q.qsize() > 0:
            print("[%s] 取到了[%s]"%(name,q.get()))
            time.sleep(1)
t = threading.Thread(target=Producer, args=('LinYaoHong',))
c = threading.Thread(target=Consumer,args=("狗狗",))
m = threading.Thread(target=Consumer,args=("狮子",))
n = threading.Thread(target=Consumer,args=("老虎",))
event = threading.Event()
t.start()
c.start()
m.start()
n.start()