1. 程式人生 > >佇列實現生產者與消費者

佇列實現生產者與消費者

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()