用 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。
立即学习“Python免费学习笔记(深入)”;
要监控中间状态或提前退出?用 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() 把这些封装掉了——省心,但也意味着失去干预时机。


















