asyncio.run()不能在已运行事件循环中调用，因设计上单线程仅允许一个顶层循环；Web框架或Jupyter中应改用await或create_task()；await后必须为Awaitable对象，同步IO需替换为异步版本或用run_in_executor()。
异步不是加个 async 就能提速，Python 的 asyncio 是协作式单线程调度器，不理解事件循环本质，写出来的异步代码可能比同步还慢。
asyncio.run() 为什么不能在已运行的事件循环里调用
常见报错：RuntimeError: asyncio.run() cannot be called from a running event loop。这不是 bug，是设计约束：一个线程只允许一个顶层事件循环实例，asyncio.run() 内部会检查 asyncio.get_event_loop().is_running()，为真就直接抛异常。
- Web 框架（如 FastAPI、Tornado）已启动自己的事件循环，你在路由函数里再调
asyncio.run()必然失败 - 正确做法是用
asyncio.create_task()或await直接调用协程，让当前循环调度它 - Jupyter 中默认启用了循环，需改用
await my_coro()而非asyncio.run(my_coro())
await 一个普通函数或同步 IO 会阻塞整个事件循环
await 后面必须是可等待对象（Awaitable），比如协程、asyncio.Future、实现了 __await__ 的对象。如果误写成 await time.sleep(1) 或 await requests.get(...)，Python 会报 TypeError: object xxx can't be used in 'await' expression；但更隐蔽的陷阱是：自己写的“假异步”函数——比如返回 None 却标了 async def，或者内部全是同步调用。
- 同步阻塞操作（文件读写、requests、time.sleep）必须替换为异步版本：
asyncio.sleep()、aiohttp.ClientSession、aiosqlite等 - 无法替换的同步库（如某些 C 扩展），要用
loop.run_in_executor()托管到线程池，否则一调就卡死整个协程队列 - 用
asyncio.current_task().get_coro()可查当前协程栈，辅助定位隐式同步点
asyncio.create_task() 和 asyncio.ensure_future() 的关键区别
两者都用于把协程提交给事件循环，但语义和适用场景不同：
-
asyncio.create_task()是推荐方式，明确表示“我要启动一个新任务”，它会立即把协程包装成Task并加入调度队列；要求必须在运行中的事件循环内调用 -
asyncio.ensure_future()更底层，可接受协程、Future、甚至任意实现了_asyncio.Future协议的对象；它不保证立即调度，且在未运行循环中也能返回 pending 的 Future —— 这容易造成“以为提交了，其实没跑”的错觉 - 若在
async def函数里启动子任务，优先用create_task()；需要统一处理多种可等待类型（比如从队列取出来的对象类型不确定）时，才考虑ensure_future()
import asyncioasync def worker(n): await asyncio.sleep(0.1) return f"done {n}"
async def main():
✅ 推荐：显式创建任务
task1 = asyncio.create_task(worker(1)) task2 = asyncio.create_task(worker(2)) # ❌ 不推荐：ensure_future 在这里无额外价值，且易混淆 # task3 = asyncio.ensure_future(worker(3)) results = await asyncio.gather(task1, task2) print(results)asyncio.run(main())
真正难的不是语法，是判断哪些 IO 调用必须异步化、哪些计算密集型操作该交给
ProcessPoolExecutor、以及如何在任务取消时做资源清理——这些不会出现在第 219 讲的标题里，但会决定你的服务到底撑不撑得住并发。
