python队列基本操作和多线程队列_Python

python队列基本操作和多线程队列

2022-09-20 17:54侯小啾 Python

pythonQueue队列模块提供了同步线程安全的队列类,包括FIFO（先入先出)队列Queue，LIFO（后入先出）队列LifoQueue,和优先级队列PriorityQueue,这些队列都实现了锁原语,能够在多线程中直接使用,可以使用队列来实现线程间的同步，下面我们就

一、队列基本操作

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())

python队列基本操作和多线程队列

如图五个值被依次取出。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())

python队列基本操作和多线程队列

如图，每取出一个值，队列大小就减一。同样每存入一个值队列大小就会加一。

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()

程序开始运行，一边存储，一边取值：

python队列基本操作和多线程队列