Python协程创建与运行全解析

本文深入剖析了Python协程从定义到执行的完整生命周期，直击新手最易踩坑的核心误区：async def仅创建协程对象而非立即执行，await与asyncio.run()的适用边界、嵌套限制及性能隐患，事件循环在不同环境（如Jupyter、Web框架）中的共存与调度策略，以及Task创建、并发控制与生命周期管理的关键细节——真正厘清“谁在什么时候把哪个协程交给了事件循环”，帮你摆脱协程静默失效、阻塞循环、任务丢失等顽疾。

async def 定义的函数不会立即执行

定义 async def 只是创建一个协程对象，不是启动它。直接调用 my_coro() 返回的是 ，不是结果——这点和普通函数截然不同，新手常误以为“写了 async 就自动跑了”。

• 必须用 await 在另一个协程里驱动，或用 asyncio.run() 显式调度
• 在同步代码里不能直接 await，会报 RuntimeError: await outside async function
• 若忘记 await 而只调用协程对象，后续逻辑可能静默跳过（比如没发 HTTP 请求、没写入文件）

asyncio.run() 是最简调度入口，但不能嵌套调用

asyncio.run() 启动事件循环、运行协程、等它结束、然后关闭循环——适合脚本主入口。但它内部会检查当前是否已有运行中的事件循环，有就直接报错：RuntimeError: asyncio.run() cannot be called from a running event loop。

• Jupyter / Flask / FastAPI 等环境已自带事件循环，此时该用 asyncio.create_task() 或 await coro
• asyncio.run() 每次调用都新建+关闭循环，频繁调用开销大，不适合高频协程启动场景
• 它隐式设置 debug=False，调试时建议改用 asyncio.run(coro, debug=True) 捕获挂起未 await 的协程警告

await 一个协程对象时，实际触发的是 __await__ 协议

Python 的 await 不限于 async def 函数返回值。任何实现了 __await__ 方法并返回迭代器的对象（如 asyncio.Future、asyncio.Task）都能被 await。这解释了为什么 await asyncio.sleep(1) 能工作：它返回一个 Future，其 __await__ 支持暂停。

• 自定义可等待对象要返回支持 .send() 和 .throw() 的迭代器，否则 await 会报 TypeError: object xxx can't be used in 'await' expression
• await 表达式本身不切换线程，只是让出控制权给事件循环；真正的 I/O 切换由底层库（如 asyncio.selector）完成
• 不要在 await 后面接普通函数调用，比如 await time.sleep(1) —— 这会阻塞整个事件循环

Task 和 create_task() 决定协程何时真正并发执行

用 await coro 是顺序执行；用 asyncio.create_task(coro) 才把协程注册进事件循环、标记为“可随时调度”，实现并发。没被 create_task() 或 asyncio.gather() 包裹的协程，即使定义了也不会跑。

• create_task() 立即把协程加入就绪队列，但首次调度时机取决于事件循环当前状态（比如刚 await 一个慢 IO，它可能立刻切过去）
• 忘记保存 create_task() 返回的 Task 对象，可能导致任务被垃圾回收（尤其没加 asyncio.shield() 时）
• 多个 create_task() 后不 await 它们，主协程退出时任务会被取消——常见于“后台日志上传”类逻辑漏掉 await asyncio.gather(*tasks)

本篇关于《Python协程创建与运行全解析》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于文章的相关知识，请关注golang学习网公众号！