Python异步函数批量执行：gather与wait区别解析

Python异步编程中，`asyncio.gather()`和`asyncio.wait()`看似相似，实则定位迥异：前者是“结果导向”的快捷工具——按调用顺序返回全部结果，适合需要确定性顺序与简洁聚合的场景，但默认一错即停；后者是“过程导向”的控制中枢——不返结果而返任务状态，支持精细监控、提前退出、分层异常处理和原生超时保留成果，适合需动态响应、容错调度或资源敏感的复杂并发逻辑。选哪个？关键不在语法，而在你心里那三个问题：要不要立刻知道哪个挂了？要不要按顺序拿结果？要不要等一半就收手？答案直指设计本质。

选 asyncio.gather() 还是 asyncio.wait()，不看文档，只看你要不要“立刻知道哪个挂了”、要不要“按顺序拿结果”、要不要“等一半就收手”。其他都是枝节。

需要按调用顺序拿到全部结果？用 gather()

比如你并发发三个 HTTP 请求，想把 resp_a、resp_b、resp_c 按传入顺序拼成列表处理，那就直接上 gather()。它返回的 list 索引和参数位置严格对应：

results = await asyncio.gather(
    fetch_user(1),
    fetch_user(2),
    fetch_user(3)
)
# results[0] 一定是 fetch_user(1) 的返回值

常见错误是误以为 wait() 也能返回有序结果——它不返回结果，只返回 done 和 pending 两个 set，里面是 Task 对象，顺序随机，还得自己遍历调 task.result()。

如果你希望某个任务失败时不中断其余任务，加 return_exceptions=True，异常会以 Exception 实例形式出现在结果里，不用额外 try/catch。

要监控中间状态或提前退出？用 wait()

比如你启动 10 个爬虫任务，只要前 3 个成功返回就停止等待，或者只要有一个抛出 TimeoutError 就立刻终止所有未完成的——这种控制粒度只有 wait() 支持。

wait() 的关键参数是 return_when，可选值包括：

• asyncio.FIRST_COMPLETED：第一个任务结束就返回
• asyncio.FIRST_EXCEPTION：第一个异常发生就返回
• asyncio.ALL_COMPLETED：全部完成才返回（默认）

注意：wait() 不自动创建 Task，传协程会报错。必须先用 asyncio.create_task() 包一层：

tasks = [asyncio.create_task(fetch(i)) for i in range(5)]
done, pending = await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)

异常处理方式完全不同

gather() 默认“失败即止”：一个任务 raise ValueError，整个 await gather(...) 就立刻抛出该异常，其余任务通常被取消。

wait() 默认“静默吞异常”：出错的任务照样进 done 集合，但你不主动调 task.exception() 就完全看不到错误。容易漏掉失败任务，尤其在日志没打全时。

典型坑点：

• 用 wait() 做批量请求，发现部分数据缺失，查半天才发现几个任务 quietly failed
• 用 gather() 时没设 return_exceptions=True，结果一个超时导致整个流程中断，而其实其他结果都有效

要不要超时控制？先看谁更合适

gather() 本身不支持 timeout 参数。硬加超时只能套 asyncio.wait_for(gather(...), timeout=5)，但这样会导致：只要超时，所有正在跑的任务全被 cancel——哪怕其中 9 个已经快完成了。

wait() 原生支持 timeout，且能保留已完成任务的结果：

done, pending = await asyncio.wait(tasks, timeout=5)
for task in done:
    try:
        result = task.result()  # 成功的结果
    except Exception as e:
        print("failed:", e)     # 失败的异常
# pending 里的任务还能手动 cancel 或重试

真正复杂的地方在于：wait() 返回的是裸 Task，你得自己区分哪些是成功、哪些是异常、哪些根本没跑完；而 gather() 把这些封装掉了——省心，但也意味着失去干预时机。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《Python异步函数批量执行：gather与wait区别解析》文章吧，也可关注golang学习网公众号了解相关技术文章。