Python异步原理与实战全解析

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《Python异步系统核心原理与实战详解》，这篇文章主要会讲到等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

asyncio.run()只能调用一次，因其内部创建并关闭事件循环；await后必须是真正的awaitable对象，如asyncio.sleep而非time.sleep；create_task()实现并发调度，而直接await则顺序执行。

asyncio.run() 为什么只能调用一次？

因为 asyncio.run() 内部会创建新事件循环、运行完就关闭。再调用就会报 RuntimeError: asyncio.run() cannot be called from a running event loop。

• 开发时别在 Jupyter 或已启动 asyncio 的环境中反复执行 asyncio.run(main())
• 想多次运行，改用 asyncio.get_event_loop().run_until_complete(main())（注意：Python 3.10+ 推荐用 asyncio.new_event_loop() + set_event_loop() 显式管理）
• asyncio.run() 隐含了 loop.close()，关闭后无法复用

await 后面必须是 awaitable，但不是所有“能 await 的东西”都安全

比如 await time.sleep(1) 看似合理，实则阻塞整个事件循环——time.sleep 是同步阻塞函数，根本不是 awaitable。

• 正确做法是用 await asyncio.sleep(1)
• 第三方库如 requests 没有异步支持，直接 await requests.get(...) 会报 TypeError: object Response can't be used in 'await' expression
• 数据库操作要用 aiomysql、asyncpg、motor 这类原生 async 驱动，不能套壳 await loop.run_in_executor(..., sqlite3.connect)（虽可行但掩盖问题）

asyncio.create_task() 和直接 await 的区别不只是“后台执行”

关键在于调度时机：await coro 是立即进入并阻塞等待完成；asyncio.create_task(coro) 把协程注册进事件循环，当前函数可继续往下走，下次循环 tick 才开始执行。

import asyncio

async def say(what, delay):
    await asyncio.sleep(delay)
    print(what)

async def main():
    task1 = asyncio.create_task(say("hello", 2))
    task2 = asyncio.create_task(say("world", 1))
    print("tasks created")
    await task1
    await task2

asyncio.run(main())

输出顺序是：tasks created → world → hello。如果写成 await say("hello", 2)，那 say("world", 1) 就得等 2 秒后才开始。

async with 和 async for 不是语法糖，它们依赖 __aenter__/__aexit__ 和 __aiter__/__anext__

没实现这些方法的对象，哪怕加了 async 前缀，也不能用于 async with。常见坑：

• aiofiles.open() 可以，open() 不行
• aiomysql.Pool 支持 async with pool.acquire()，但自己写的普通上下文管理器加 async 不等于自动支持
• async for line in file: 要求 file 实现 __aiter__，不是所有文件对象都满足（比如 io.StringIO 就不行）

本篇关于《Python异步原理与实战全解析》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于文章的相关知识，请关注golang学习网公众号！