队列

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

# 队列：FIFO即First in First Out,先进先出
from queue import Queue

q = Queue()

for i in range(5):
    q.put(i)

while not q.empty():
    print(q.get())

栈

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

# 栈：LIFO即Last in First Out,后进先出
from queue import LifoQueue

q = LifoQueue()

for i in range(5):
    q.put(i)

while not q.empty():
    print(q.get())

queue介绍

在python中，多个线程之间的数据是共享的，多个线程进行数据交换的时候，不能够保证数据的安全性和一致性，所以当多个线程需要进行数据交换的时候，队列就出现了，队列可以完美解决线程间的数据交换，保证线程间数据的安全性和一致性

queue模块有三种队列及构造函数

  1. Python queue模块的FIFO队列先进先出。 class queue.Queue(maxsize)
  2. LIFO类似于堆，即先进后出。 class queue.LifoQueue(maxsize)
  3. 还有一种是优先级队列级别越低越先出来。 class queue.PriorityQueue(maxsize)

queue模块中的常用方法

  • queue.qsize() 返回队列的近似大小。注意，队列大小大于0并不保证接下来的get()调用不会被阻塞，队列大小小于maxsize也不保证接下来的put()调用不会被阻塞。
  • queue.empty() 如果队列为空，返回True,反之False
  • queue.full() 如果队列满了，返回True,反之False
  • queue.full 与 maxsize 大小对应
  • queue.get([block[, timeout]]) 从队列中移除并返回一个数据。如果可选的参数block为真且timeout为空对象（默认的情况，阻塞调用，无超时），阻塞调用进程直到有数据可用。如果timeout是个正整数，阻塞调用进程最多timeout秒，如果一直无数据可用，抛出Empty异常（带超时的阻塞调用）。如果block为假，如果有数据可用返回数据，否则立即抛出Empty异常（非阻塞调用，timeout被忽略）。
  • queue.get_nowait() 相当queue.get(False)
  • queue.put(item[, block[, timeout]]) 将item放入队列中。如果可选的参数block为真且timeout为空对象（默认的情况，阻塞调用，无超时），如有必要（比如队列满），阻塞调用线程，直到有空闲槽可用。如果timeout是个正整数，阻塞调用进程最多timeout秒，如果一直无空闲槽可用，抛出Full异常（带超时的阻塞调用）。如果block为假，如果有空闲槽可用将数据放入队列，否则立即抛出Full异常（非阻塞调用，timeout被忽略）。
  • queue.put_nowait(item) 相当queue.put(item, False)
  • queue.task_done() 在完成一项工作之后，queue.task_done()函数向任务已经完成的队列发送一个信号
  • queue.start():启动线程活动
  • queue.join() 阻塞调用线程，直到队列中的所有任务被处理掉。