Python queue使用方法

在Python中，queue 是一个提供线程安全队列操作的模块，它支持多种类型的队列，包括先进先出（FIFO）和后进先出（LIFO）。以下是如何使用 Python queue 模块的一些基本示例：

安装

通常情况下，queue 模块是 Python 标准库的一部分，不需要单独安装。但是，如果你使用的是特定的环境或需要确保模块可用，可以使用 pip 安装：

pip install queue

基本用法

Queue（FIFO）

from queue import Queue# 创建一个 FIFO 队列
q = Queue()# 向队列中添加元素
q.put('a')
q.put('b')
q.put('c')# 从队列中获取元素
first_item = q.get()
print(first_item)  # 输出: 'a'# 检查队列是否为空
is_empty = q.empty()
print(is_empty)  # 输出: False# 获取队列中的元素数量
size = q.qsize()
print(size)  # 输出: 2# 从队列中移除并返回一个元素，如果队列为空，则阻塞
item = q.get()
print(item)  # 输出: 'b'# 清空队列
q.queue.clear()# 再次检查队列是否为空
is_empty = q.empty()
print(is_empty)  # 输出: True

LifoQueue（LIFO）

LIFO 队列（栈）的使用方法与 Queue 类似，但是它遵循后进先出的原则。

from queue import LifoQueue# 创建一个 LIFO 队列
lq = LifoQueue()# 向队列中添加元素
lq.put('a')
lq.put('b')
lq.put('c')# 从队列中获取元素，后进先出
last_item = lq.get()
print(last_item)  # 输出: 'c'

PriorityQueue（优先队列）

优先队列可以根据元素的优先级进行排序。

from queue import PriorityQueue# 创建一个优先队列
pq = PriorityQueue()# 向队列中添加元素，可以指定优先级
pq.put(('a', 1))
pq.put(('b', 2))
pq.put(('c', 0))# 获取优先级最高的元素
highest_priority_item = pq.get()
print(highest_priority_item)  # 输出: ('c', 0)

线程安全

queue 模块中的所有队列操作都是线程安全的，可以在多线程环境中使用。

import threadingdef worker():while not q.empty():item = q.get()print(f"Thread {threading.current_thread().name} processed item: {item}")# 创建线程
t1 = threading.Thread(target=worker)
t2 = threading.Thread(target=worker)# 启动线程
t1.start()
t2.start()# 在主线程中向队列添加工作
for i in range(5):q.put(i)# 等待所有线程完成
t1.join()
t2.join()