### 队列的基本概念 队列是一种先进先出（FIFO）的线性数据结构，广泛应用于任务调度、缓冲区管理、广度优先搜索等场景。Python 提供了内置的 `queue` 模块，用于实现线程安全的队列操作，支持多种类型的队列[^1]。 ### Python 中的队列类型 `queue` 模块提供了以下三种主要的队列类： 1. **`queue.Queue`**：先进先出（FIFO）队列。 2. **`queue.LifoQueue`**：后进先出（LIFO）队列，类似于栈。 3. **`queue.PriorityQueue`**：优先级队列，元素按优先级顺序出队。 这些队列类适用于多线程编程中数据交换的需求，确保线程安全[^2]。 ### 队列的基本操作 #### 创建队列 可以使用 `queue.Queue()` 创建一个 FIFO 队列，并通过 `maxsize` 参数限制队列大小： ```python import queue # 创建一个最大容量为3的FIFO队列 q = queue.Queue(maxsize=3) ``` 若不指定 `maxsize` 或设置为小于1的值，队列将为无限容量[^4]。 #### 入队操作（`put`） 使用 `put()` 方法向队列中添加元素： ```python q.put(1) q.put(2) q.put(3) ``` 若队列已满，调用 `put()` 将阻塞，直到队列中有空间可用[^3]。 #### 出队操作（`get`） 使用 `get()` 方法从队列中取出元素： ```python print(q.get()) # 输出: 1 print(q.get()) # 输出: 2 ``` 若队列为空，调用 `get()` 将阻塞，直到队列中有元素可用[^3]。 #### 判断队列状态 - `empty()`：判断队列是否为空。 - `full()`：判断队列是否已满（仅适用于设置了 `maxsize` 的队列）。 - `qsize()`：获取队列中当前元素的数量。 ```python print(q.empty()) # 输出: False print(q.full()) # 输出: True print(q.qsize()) # 输出: 1 ``` ### 队列在多线程中的应用 在多线程编程中，队列常用于实现生产者-消费者模型。生产者线程使用 `put()` 方法向队列中添加数据，消费者线程使用 `get()` 方法取出数据进行处理。这种方式可以实现线程间解耦，提高系统的可扩展性和可维护性[^3]。 ```python import threading def producer(q): for i in range(5): q.put(i) print(f"Produced: {i}") def consumer(q): while True: item = q.get() if item is None: break print(f"Consumed: {item}") q = queue.Queue() # 创建生产者线程 t1 = threading.Thread(target=producer, args=(q,)) t1.start() # 创建消费者线程 t2 = threading.Thread(target=consumer, args=(q,)) t2.start() t1.join() q.put(None) # 发送结束信号 t2.join() ``` ### 队列的变种 除了标准的 FIFO 队列，`queue` 模块还提供了以下变种： 1. **`LifoQueue`**：后进先出队列，最后插入的元素最先被取出。 2. **`PriorityQueue`**：优先级队列，元素按照优先级排序，优先级高的元素先出队。 ```python # LIFO队列示例 lifo_q = queue.LifoQueue() lifo_q.put(1) lifo_q.put(2) print(lifo_q.get()) # 输出: 2 # 优先级队列示例 priority_q = queue.PriorityQueue() priority_q.put((2, 'low priority')) priority_q.put((1, 'high priority')) print(priority_q.get()) # 输出: (1, 'high priority') ``` ###