Pythonasyncio异常处理详解

Python asyncio 的异常处理远比同步代码复杂，因为协程异常不会自动冒泡至主线程，若不主动捕获或检查，极易导致静默失败、资源泄漏甚至后台任务意外崩溃；本文系统梳理了四大核心场景——直接 await 协程时的即时捕获、create_task 后必须显式 await 或调用 result() 才能触发异常、gather 与 wait 在并发执行中截然不同的异常传播策略（如 return_exceptions=True 的容错模式），以及通过 loop.set_exception_handler 实现的全局监控兜底机制，帮你避开异步开发中最隐蔽也最致命的异常陷阱，真正写出健壮、可维护的异步应用。

在使用 Python 的 asyncio 编程时，异常处理比同步代码更复杂。协程可能在事件循环中异步执行，异常不会自动冒泡到主线程，若不妥善处理，会导致程序静默失败或资源泄漏。掌握正确的异常捕获方式，是编写健壮异步应用的关键。

直接 await 协程时的异常捕获

当你直接调用并 await 一个协程对象时，可以像处理普通函数一样使用 try-except 捕获异常。

示例：

import asyncio
<p>async def risky_task():
await asyncio.sleep(1)
raise ValueError("出错了")</p><p>async def main():
try:
await risky_task()
except ValueError as e:
print(f"捕获异常: {e}")</p><p>asyncio.run(main())
</p>

通过 create_task 启动任务的异常处理

使用 asyncio.create_task() 创建的任务会在后台运行，即使协程抛出异常，也不会立即被捕获。必须显式等待任务或检查其状态。

正确做法：保留任务引用并在合适时机 await 或检查异常。

async def main():
    task = asyncio.create_task(risky_task())
    try:
        await task
    except ValueError as e:
        print(f"任务异常: {e}")

如果不 await 任务，异常可能直到程序结束才被打印（通过 loop.set_exception_handler 可定制行为）。

并发执行中的异常捕获（gather 与 wait）

当需要同时运行多个协程时，常用 asyncio.gather 和 asyncio.wait，它们对异常的处理方式不同。

asyncio.gather 默认遇到第一个异常就停止其他任务（可配置 return_exceptions=True 改变行为）：

async def main():
    try:
        await asyncio.gather(
            good_task(),
            risky_task()
        )
    except ValueError as e:
        print(f"Gather 捕获: {e}")  # 立即中断

开启 return_exceptions=True 后，异常作为结果返回，不会中断其他任务：

results = await asyncio.gather(
    good_task(),
    risky_task(),
    return_exceptions=True
)
for r in results:
    if isinstance(r, Exception):
        print(f"任务异常: {r}")

asyncio.wait 返回完成和未完成的任务集合，需手动检查每个完成任务的异常：

done, pending = await asyncio.wait([task1, task2], return_when=asyncio.FIRST_EXCEPTION)
for t in done:
    if t.exception():
        print(f"任务出错: {t.exception()}")

全局异常处理器

可以通过设置事件循环的异常处理器来捕获未被处理的任务异常。

def custom_exception_handler(loop, context):
    msg = context.get("exception", context["message"])
    print(f"全局捕获异常: {msg}")
<p>loop = asyncio.get_event_loop()
loop.set_exception_handler(custom_exception_handler)
</p>

这适用于监控后台任务的意外崩溃，但不能替代正常的异常处理逻辑。

基本上就这些。关键是要意识到 async/await 中的异常不会自动传播，必须主动 await 任务或检查其结果。合理使用 try-except、gather 的参数以及全局处理器，才能构建可靠的异步系统。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于文章的相关知识，也可关注golang学习网公众号。