from queue import Queue from threading import Thread import time q = Queue() def add_to_queue(): for i in range(10): print('添加') q.put(i) time.sleep(0.01) def get_from_queue(): while True: print(q.get()) q.task_done() t1 = Thread(target=add_to_queue) #把当前进程设置为守护进程 # 什么是守护线程: 主线程结束了, 该子线程会自动结束 t1.setDaemon(True) t1.start() time.sleep(0.1) print(q.unfinished_tasks) t2 = Thread(target=get_from_queue) #把当前进程设置为守护进程 t2.setDaemon(True) t2.start() print(q.unfinished_tasks) # t1.join() # t2.join()# 由于t2对应任务是一个死循环, 永远都不会结束 #让主线等待队列任务完成 q.join()
python 队列结合线程的使用
猜你喜欢
转载自www.cnblogs.com/12580s/p/9366549.html
今日推荐
周排行