""" queue 的最核心的几个功能 """
import threading
import queue
def producer(q):
""" 生产者 """
for i in range(10):
q.put(i)
def consumer(q):
""" 消费者 """
while True:
item = q.get()
print('Consume:',item)
q.task_done()
q = queue.Queue()
t1 = threading.Thread(target=consumer,args=(q,),daemon=True)
t2 = threading.Thread(target=consumer,args=(q,),daemon=True)
t1.start()
t2.start()
producer(q)
q.join()
版权属于:
irx999
作品采用:
《
署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0)
》许可协议授权
评论 (0)