import queue,time
import threading
def worker():
while True:
item = q.get()
if item is None:
break
print(item)
time.sleep(3)
q.task_done()
q = queue.Queue()
创建5个工作线程
for i in range(5):
t = threading.Thread(target=worker)
t.start()
往队列中添加10个任务
for item in range(10):
q.put(item)
等待队列中的所有任务都被处理完成
q.join()
结束所有工作线程
for i in range(5):
q.put(None)