Python的queue模塊提供線程安全的隊(duì)列，適用于多線程數(shù)據(jù)傳遞；2. Queue()為FIFO隊(duì)列，LifoQueue()為后進(jìn)先出隊(duì)列，PriorityQueue()按優(yōu)先級(jí)出隊(duì)；3. 多線程中通過put()入隊(duì)、get()出隊(duì)，配合task_done()和join()確保任務(wù)完成；4. 生產(chǎn)者-消費(fèi)者模型是典型應(yīng)用，需用None信號(hào)通知消費(fèi)者結(jié)束，所有任務(wù)完成后程序正確退出。

Python 中的 queue 模塊提供了線程安全的隊(duì)列實(shí)現(xiàn)，常用于多線程編程中安全地傳遞數(shù)據(jù)。下面是一個(gè)簡(jiǎn)單實(shí)用的 queue 使用示例，幫助你快速理解其基本用法。

1. 基本的 Queue（FIFO 隊(duì)列）

import queue

# 創(chuàng)建一個(gè)先進(jìn)先出的隊(duì)列
q = queue.Queue()

# 添加元素（入隊(duì)）
q.put("任務(wù)1")
q.put("任務(wù)2")
q.put("任務(wù)3")

# 獲取元素（出隊(duì)）
while not q.empty():
    item = q.get()
    print(f"處理: {item}")
    q.task_done()  # 表示任務(wù)已完成（在線程中很重要）

輸出：

處理: 任務(wù)1
處理: 任務(wù)2
處理: 任務(wù)3

Queue() 默認(rèn)是 FIFO（先進(jìn)先出），適合大多數(shù)場(chǎng)景。

2. LIFO 隊(duì)列（類似棧）

import queue

q = queue.LifoQueue()  # 后進(jìn)先出

q.put("任務(wù)1")
q.put("任務(wù)2")
q.put("任務(wù)3")

while not q.empty():
    item = q.get()
    print(f"處理: {item}")
    q.task_done()

輸出：

處理: 任務(wù)3
處理: 任務(wù)2
處理: 任務(wù)1

LifoQueue 可用于模擬棧結(jié)構(gòu)，比如撤銷操作、遞歸替代等。

3. 優(yōu)先級(jí)隊(duì)列（Priority Queue）

import queue

q = queue.PriorityQueue()

# 添加任務(wù)，格式為 (優(yōu)先級(jí), 數(shù)據(jù))
# 數(shù)字越小，優(yōu)先級(jí)越高
q.put((3, "低優(yōu)先級(jí)任務(wù)"))
q.put((1, "高優(yōu)先級(jí)任務(wù)"))
q.put((2, "中優(yōu)先級(jí)任務(wù)"))

while not q.empty():
    priority, task = q.get()
    print(f"處理優(yōu)先級(jí) {priority}: {task}")
    q.task_done()

輸出：

處理優(yōu)先級(jí) 1: 高優(yōu)先級(jí)任務(wù)
處理優(yōu)先級(jí) 2: 中優(yōu)先級(jí)任務(wù)
處理優(yōu)先級(jí) 3: 低優(yōu)先級(jí)任務(wù)

常用于任務(wù)調(diào)度系統(tǒng)，如作業(yè)排隊(duì)、事件處理等。

4. 多線程中使用 Queue（生產(chǎn)者-消費(fèi)者模型）

import queue
import threading
import time

def producer(q):
    for i in range(5):
        q.put(f"任務(wù)-{i}")
        print(f"生產(chǎn): 任務(wù)-{i}")
        time.sleep(0.5)

def consumer(q):
    while True:
        item = q.get()
        if item is None:
            break
        print(f"消費(fèi): {item}")
        time.sleep(1)
        q.task_done()

# 創(chuàng)建隊(duì)列
q = queue.Queue()

# 創(chuàng)建線程
t1 = threading.Thread(target=producer, args=(q,))
t2 = threading.Thread(target=consumer, args=(q,))

t1.start()
t2.start()

t1.join()  # 等待生產(chǎn)者完成

# 發(fā)送結(jié)束信號(hào)
q.put(None)  # 通知消費(fèi)者結(jié)束

t2.join()  # 等待消費(fèi)者完成

print("所有任務(wù)完成")

這是 queue 最典型的用途：線程間通信，避免競(jìng)態(tài)條件。

小貼士

• q.put(item)：入隊(duì)，可選參數(shù) block=True, timeout=None
• q.get()：出隊(duì)，同樣支持阻塞和超時(shí)
• q.task_done()：必須在處理完任務(wù)后調(diào)用
• q.join()：阻塞直到隊(duì)列中所有任務(wù)都被 task_done() 處理
• q.empty() 和 q.full() 不是線程安全的，僅作參考

基本上就這些。queue 模塊簡(jiǎn)單但強(qiáng)大，尤其適合多線程任務(wù)調(diào)度。不復(fù)雜，但容易忽略 task_done() 和 join() 的配合使用。

以上是Python隊(duì)列示例的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！