Queue是python标准库中的线程安全的队列(FIFO)实现, 提供了一个适用于多线程编程的先进先出的数据结构
先入先出、后入先出、优先级队列
# 普通队列,先入先出,maxsize=0意味着队列没有上限 q0 = queue.Queue(maxsize=2) # last in first out,后入先出 q1 = queue.LifoQueue() # 优先顺序队列,数值越小优先级越高,使用方法:q2.put(1,‘name‘) q2 = queue.PriorityQueue()
1. 入队
put:put方法是一个阻塞的方法,即如果设置了队列的大小,当队列已经满了,还继续put入队,会阻塞卡死
q0.put(1) # 给队列放置一个内容;put是阻塞的方法,如果队列设置了上限,当超出队列长度时,会阻塞卡死
put_nowait: 此方法不是阻塞的方法,但是如果入队时超出队列大小,会报错:queue.Full
q0.put_nowait(3) # 给队列放置一个内容;此方法不会阻塞,但是当超出队列设定的长度时会报错
2. 出队
get方法:get方法也是阻塞的方法,当队列为空时,会阻塞
# get方法获取队列的值,是阻塞的方法,当队列为空的时候,会阻塞卡死,每调用get一次,出队一个元素 print(q0.get()) print(q0.get())
get_nowait方法:不会阻塞,但是当队列为空时,会报错:queue.Empty
# 取值的方法,不会阻塞,但是会报错 print(q0.get_nowait())
3. 其他方法:
等待队列处理完毕:
# 当队列还有任务没有被处理时,会一直阻塞,直到队列中的 任务(put进去的东西) 全被 get 并被处理掉(task_done) q0.join() # 结束一个任务 q0.task_done()
队列是否满了或者空了:
# 判断队列是否满了或空了,如果是,返回True print(‘Full:‘,q0.full()) print(‘Empty:‘,q0.empty())
查看队列大小:
# 队列大小 print(q0.qsize())
原文:https://www.cnblogs.com/wztshine/p/11970048.html