import threading,time,queue,random

def scz():
    while True:
 num=random.randint(1,100000)
 q.put(num)#放進佇列
 print("生產者產生了%d資料" %(num))
 time.sleep(5)
 q.task_done()#完成任務

def xfz():
 while True:
 item=q.get()#從佇列取出
 if item is None:
 break
 print("消費者消費了%d資料"%item)
 time.sleep(3)
 q.task_done()


if __name__ == '__main__':
 
 q=queue.Queue()

 
 for i in range(4):
 threading.Thread(target=scz).start()
 
 for i in range(3):
 threading.Thread(target=xfz).start()