队列基本操作

from queue import Queue

q = Queue(5)  # 创建一个容量为5的队列。如果给一个小于0的数，则队列为无限大小。（这是官方的解释，实际不是无限大小，而是跟内存有关）

# 存储数据
q.put(123)  # 数值 
q.put('hello world!')  # 字符串
q.put(['hello', 'world'])  # 列表
q.put(('hello', 'world'))  # 元组
q.put({'hello': 'world'})  # 字典

# 如果再试图存储第六个，则会发生阻塞，因为容量已设定为5
# q.put({'hello': 'python'})

取出队列中的值

print(q.get())
print(q.get())
print(q.get())
print(q.get())
print(q.get())

在这里插入图片描述
如图五个值被依次取出。Queue队列遵循的是先进先出。

q.put_nowait()
q.put_nowait()方法可以无阻碍地向队列中添加内容，如果队列已满则会立即报错，不会等待（即不会发生阻塞）。
q.get_nowait()
q.get_nowait()方法可以无阻碍地从队列中取出内容，如果队列是空的则也会直接报错，不会等待。

具体使用不再示例。

查看队列当前大小

q.qsize()

print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())

在这里插入图片描述
如图，每取出一个值，队列大小就减一。同样每存入一个值队列大小就会加一。

q.full()
判断队列是否是满的。
q.empty()
判断队列是否是空的。

print(q.full())
print(q.get())
print(q.get())
print(q.full())
print(q.empty())
print(q.get())
print(q.get())
print(q.get())
print(q.empty())

在这里插入图片描述

多线程队列

from queue import Queue
import threading
import time


# 存储值，每隔一秒存储一个
def set_value(q):
    num = 0
    while True:
        q.put(num)
        num += 1
        time.sleep(1)

# 取值，不间断地取
def get_value(q):
    while True:
        print(q.get())


if __name__ == '__main__':
    q = Queue(4)
    t1 = threading.Thread(target=set_value, args=(q, ))
    t2 = threading.Thread(target=get_value, args=(q, ))

    t1.start()
    t2.start()