Python asyncio.Task异常未立即抛出，需主任务完成才触发的问题咨询

我刚复现了你遇到的这个场景，先把你的代码贴出来方便大家参考：

import asyncio
@asyncio.coroutine
def coro1():
    print("coro1 primed")
    yield
    raise Exception("abc")
@asyncio.coroutine
def coro2(loop):
    try:
        print("coro2 primed")
        ts = [asyncio.Task(coro1(),loop=loop) for _ in range(2)]
        res = yield from asyncio.sleep(10)
        print(res)
    except Exception as e:
        print(e)
        raise
loop= asyncio.get_event_loop()
loop.run_until_complete(coro2(loop))

为什么异常会等10秒才触发？ #

这其实是asyncio的默认设计逻辑：当你创建一个Task但没有主动等待它（比如用yield from/await），也没有主动获取它的结果（task.result()），那么这个Task抛出的异常会被暂时“缓存”起来，不会立刻中断当前正在运行的主任务。

具体过程是这样的：

1. coro1抛出异常后，对应的Task会进入“异常完成”状态，但因为没有任何代码在监听这个Task的结果，asyncio不会立刻把异常传播到主任务流里。
2. 事件循环会继续执行当前的活跃任务——也就是coro2里的asyncio.sleep(10)，直到这个sleep任务完成，coro2整个执行完毕。
3. 当loop.run_until_complete结束后，事件循环会做收尾检查：遍历所有已完成但异常未被处理的Task，然后把这些异常抛出来（或者打印，具体取决于Python版本）。

这种设计是为了支持“fire-and-forget”的任务场景，但确实像你说的，在复杂系统里会埋下隐患：如果主任务是长期运行的循环，未处理的Task异常会被隐藏，直到主任务终止，导致进程看似正常运行但实际已经出问题。

怎么让异常立刻触发？ #

如果你希望子任务的异常能立刻终止程序，可以试试这两种方法：

• 等待所有子任务：用asyncio.gather把子任务和sleep任务合并，这样任何子任务的异常都会立刻传播到主任务：

  # 修改coro2里的代码
  res = yield from asyncio.gather(*ts, asyncio.sleep(10))
  

  这样当coro1抛出异常时，gather会立刻抛出异常，coro2的try-except会马上捕获到，程序直接退出，不用等10秒。
• 给Task加异常回调：通过task.add_done_callback手动处理异常，甚至直接终止事件循环：

  def handle_task_exception(task):
      try:
          task.result()  # 这里会触发Task存储的异常
      except Exception as e:
          print(f"子任务报错了: {e}")
          loop.stop()  # 立刻终止事件循环
  
  # 创建Task后添加回调
  ts = [asyncio.Task(coro1(), loop=loop) for _ in range(2)]
  for t in ts:
      t.add_done_callback(handle_task_exception)
  

异常处理的源码追踪 #

你说在run_until_complete的except块设断点没触发，那是因为这个异常不是在run_until_complete直接捕获的，而是在事件循环的收尾流程里处理的。

以Python 3.7+的源码为例，你可以重点看这些位置：

1. asyncio.tasks.Task.__step：当Task执行抛出异常时，会调用self._loop._add_uncaught_exception(self)，把这个异常Task添加到事件循环的_uncaught_exceptions集合里。
2. asyncio.base_events.BaseEventLoop._run_until_complete_future：当run_until_complete的主任务完成后，会触发事件循环的收尾逻辑。
3. asyncio.base_events.BaseEventLoop._handle_exception：最终处理未捕获异常的方法，默认会把异常打印到stderr，或者在特定场景下重新抛出异常。

你可以在这些方法里设置断点，就能看到异常的处理流程了。

内容的提问来源于stack exchange，提问作者YNX