Python asyncio.run() 里嵌套 asyncio.run() 会发生什么

asyncio.run() 不允许嵌套调用,会在已有运行事件循环时抛出 RuntimeError;正确做法是用 await、create_task 或 ensure_future 在当前 loop 中调度协程。

asyncio.run() 嵌套调用会直接抛出 RuntimeError

Python 不允许在已运行的事件循环内再次调用 asyncio.run()。它内部会检查当前线程是否已有正在运行的事件循环(通过 asyncio.get_event_loop()),如果检测到“已有运行中的 loop”,就立刻 raise:RuntimeError: asyncio.run() cannot be called from a running event loop

这不是警告,是硬性限制 —— 无论你嵌套得有多深(比如在 async def 函数里、在 asyncio.to_thread() 里、甚至在 loop.call_soon() 回调中),只要顶层是 asyncio.run() 启动的,里面再调一次就会崩。

常见误用场景:在协程里试图“重启”或“重进”事件循环

典型错误模式是:想在一个异步函数里临时跑另一个独立的异步任务,又懒得理清 await 链,就随手写 asyncio.run(another_coro())。这在同步函数里能跑,但在协程里绝对不行。

  • 你写的函数是 async def,说明它必须被 await 或由事件循环调度 —— 它本身就在 loop 里
  • asyncio.run() 是为“从同步入口启动异步世界”设计的,不是协程内部的工具函数
  • 即使那个被调用的 another_coro() 很短、不 await 任何东西,也逃不过检测

正确替代方案:用 await + ensure_future / create_task

你需要的不是“新 run”,而是“在当前 loop 里调度一个新协程”。所有合法做法都绕不开 await 或显式提交给当前 loop:

  • 如果逻辑简单、可直连:直接 await another_coro()
  • 如果想并发执行(不等它结束):asyncio.create_task(another_coro())(推荐,Python 3.7+)
  • 如果需要兼容老版本或更底层控制:asyncio.ensure_future(another_coro())
  • 如果必须从同步代码片段切入(如回调里):asyncio.get_event_loop().create_task(...),但要确保 loop 确实存在且未关闭

注意:create_task() 返回的是 Task 对象,不会自动 await;若需等待结果,仍要 await task

唯一能“嵌套 run”的情况:不同线程 + 显式关闭 loop

理论上,如果你在新线程里调用 asyncio.run(),它是安全的

—— 因为每个线程默认有独立的事件循环状态。但要注意:

  • 主线程的 loop 和子线程的 loop 完全隔离,无法共享 FutureTask
  • 不能跨线程 await 同一个协程(会报 RuntimeError: no running event loop
  • 频繁启停 asyncio.run() 有明显开销,不建议用于高频路径
  • 若子线程里用了 asyncio.run(),记得别在主线程里尝试 get_event_loop() 拿它的 loop —— 拿不到

真正需要多 loop 协作时,应该用 asyncio.new_event_loop() + set_event_loop() 手动管理,而不是依赖 run()

最常被忽略的一点:错误信息里说的“running event loop”,指的不是“loop 对象存在”,而是“loop 正在 run_forever() 或 run_until_complete() 中”。哪怕你只是调用了 loop.run_once(),只要 loop 处于 active 状态,asyncio.run() 就会拒绝入场。