快捷導(dǎo)航

python 線程池順序執(zhí)行的方法實現(xiàn)

更新時間：2025年08月19日 09:08:16 作者：AI浩

在Python中,線程池默認是并發(fā)執(zhí)行任務(wù)的,但若需要實現(xiàn)任務(wù)的順序執(zhí)行,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習或者工作具有一定的參考學(xué)習價值,需要的朋友們下面隨著小編來一起學(xué)習學(xué)習吧

方案一：強制單線程（偽順序執(zhí)行）

將線程池的最大工作線程數(shù)設(shè)為1，任務(wù)會按提交順序依次執(zhí)行（但失去了并發(fā)意義）：

from concurrent.futures import ThreadPoolExecutor

def task(n):
    return f"Task {n} completed"

with ThreadPoolExecutor(max_workers=1) as executor:  # 單線程
    futures = [executor.submit(task, i) for i in range(1, 6)]
    for future in futures:
        print(future.result())

方案二：按提交順序獲取結(jié)果

保持并發(fā)執(zhí)行，但按任務(wù)提交順序獲取結(jié)果（若任務(wù)完成順序不確定）：

from concurrent.futures import ThreadPoolExecutor

def task(n):
    import time, random
    time.sleep(random.uniform(0, 1))  # 模擬隨機耗時
    return f"Task {n} completed"

with ThreadPoolExecutor() as executor:
    # 提交任務(wù)并按順序存儲 Future 對象
    futures = [executor.submit(task, i) for i in range(1, 6)]
    # 按提交順序逐個獲取結(jié)果（會阻塞直到對應(yīng)任務(wù)完成）
    for future in futures:
        print(future.result())  # 輸出順序始終是 1,2,3,4,5

方案三：任務(wù)間依賴控制

若任務(wù)需要嚴格按順序執(zhí)行（前一個任務(wù)完成后才能執(zhí)行下一個），使用同步鎖：

from concurrent.futures import ThreadPoolExecutor
import threading

lock = threading.Lock()
current_step = 0

def sequential_task(n):
    global current_step
    while True:
        with lock:
            if n == current_step + 1:
                print(f"Executing Task {n}")
                current_step = n
                break

with ThreadPoolExecutor(max_workers=5) as executor:
    executor.map(sequential_task, range(1, 6))  # 嚴格按 1→2→3→4→5 執(zhí)行

方案四：隊列順序消費

使用隊列（Queue）控制任務(wù)執(zhí)行順序：

from concurrent.futures import ThreadPoolExecutor
import queue

def worker(q):
    while not q.empty():
        task_id = q.get()
        print(f"Processing Task {task_id}")
        q.task_done()

task_queue = queue.Queue()
for i in range(1, 6):
    task_queue.put(i)

with ThreadPoolExecutor() as executor:
    # 啟動多個線程消費隊列（實際按隊列順序執(zhí)行）
    for _ in range(3):  # 3個工作線程
        executor.submit(worker, task_queue)
    task_queue.join()  # 等待所有任務(wù)完成

適用場景總結(jié)

方案	特點	適用場景
單線程池	簡單但無并發(fā)	調(diào)試或資源受限環(huán)境
順序獲取結(jié)果	并發(fā)執(zhí)行，順序處理結(jié)果	結(jié)果需按提交順序處理（如日志寫入）
任務(wù)間依賴鎖	嚴格順序執(zhí)行	任務(wù)有前后依賴關(guān)系
隊列消費	動態(tài)任務(wù)按隊列順序執(zhí)行	生產(chǎn)者-消費者模型