Python 异步函数为何不能随意调用

不是必须await，而是不await就不会执行其异步逻辑；async函数返回协程对象，直接调用不触发函数体内任何代码（包括print、await等），仅在被await、create_task或gather调度时才执行。

async 函数调用必须 await 吗？

不是“必须”，而是“不 await 就不会执行其异步逻辑”。async def 定义的函数返回的是一个 coroutine 对象，不是结果。直接调用 my_async_func() 不会运行函数体内的 await 表达式，也不会等待 I/O，只是生成一个待调度的协程对象。

• 直接调用后不 await，函数体根本不会进入执行（比如里面的 print、await asyncio.sleep(1) 都不会触发）
• 若把它丢给 asyncio.create_task() 或传入 asyncio.gather()，那是在事件循环中“安排执行”，仍需最终被 loop 驱动
• 在同步上下文（如普通函数、脚本顶层）里调用 async 函数却不 await，通常只是漏掉逻辑，不会报错；但若你期望它完成某事（比如发请求、写文件），那就完全没发生

在同步函数里调用 async 函数会怎样？

会报 RuntimeError: no running event loop 或触发

• 普通函数（def）没有事件循环上下文，无法驱动 coroutine
• 常见错误写法：def wrapper(): return fetch_data()，其中 fetch_data 是 async def —— 这里只返回协程对象，不是数据
• 解决路径只有两条：
    • 把调用方也改成 async def，并在上层用 await
    • 在同步函数里显式启动事件循环，例如用 asyncio.run(fetch_data())（仅限最外层，不可嵌套多次调用）

为什么不能用 threading 或 multiprocessing “绕过” await？

能绕过语法限制，但会破坏异步语义，大概率引发错误或资源竞争。

• threading.Thread(target=async_func).start()：失败，因为 async_func() 返回协程对象，不是可调用的同步函数
• 真正想跑，得写成 threading.Thread(target=lambda: asyncio.run(async_func())).start() —— 但这会为每个线程新建一个独立 event loop，且无法与主线程的 loop 通信
• 更严重的是：异步库（如 aiohttp、aiomysql）内部假设单 loop 上下文，跨线程调用可能触发 RuntimeError: Task got bad yield 或连接复用失效
• 简单说：异步不是“多线程加速”，而是“单线程并发等待”，混用模型会让调度失控

哪些地方容易忽略 await？

最容易栽在条件分支、异常处理、列表推导和装饰器里。

• 条件中漏 await：if check_user(): ...，而 check_user 是 async 函数 → 实际判断的是协程对象的真值（恒为 True）
• try/except 包裹 async 调用但没 await：try: load_config() except Exception: ... → 异常根本不会抛出，因为函数体没运行
• 列表推导误写：[call_api(x) for x in items] → 得到一堆协程对象，不是结果；应改用 await asyncio.gather(*[call_api(x) for x in items])
• 自定义装饰器未适配 async：给 async def 函数加同步装饰器（如计时器），可能吞掉协程对象或导致 await 失效

async 函数不是“更快的 def”，它是另一种执行契约：调用者必须参与调度。漏掉 await 不是语法错误，而是逻辑断连——看起来没报错，但该做的事一件都没做。