Python协程原理是什么_asyncio机制

4次阅读

python协程是可主动暂停和恢复执行的函数,不依赖操作系统线程调度,由事件循环驱动,通过async/await语法实现单线程高并发

Python协程原理是什么_asyncio机制

Python协程的本质,是**可主动暂停和恢复执行的函数**,它不依赖操作系统线程调度,而由程序自己控制流转——遇到 I/O 等待时让出 CPU,转去执行其他任务,从而在单线程内实现高并发。asyncio 是支撑这一能力的完整框架,其核心不是“多线程”,而是“事件驱动 + 协程协作”。

协程不是线程,是轻量级执行单元

协程没有独立、不抢占 CPU、切换开销极小(微秒级)。它靠 async/await 语法定义和挂起:调用 async def 函数返回的是一个协程对象(coroutine Object),此时函数体并未执行;只有被事件循环调度并 await 时,才真正开始运行,并在每个 await 表达式处暂停。

关键点:

  • 协程暂停时,不阻塞整个线程,只是把控制权交还给事件循环
  • 暂停后状态被保存(局部变量、执行位置等),下次恢复时从中断处继续
  • 与生成器(yield)原理相似,但专为异步设计,语义更清晰、API 更统一

事件循环是 asyncio 的调度中枢

事件循环(Event Loop)是 asyncio 的心脏,它是一个持续运行的无限循环,负责:

立即学习Python免费学习笔记(深入)”;

  • 维护就绪任务队列(ready queue)和等待队列(如等待网络响应、文件读取完成)
  • 通过系统调用(如 epollkqueueselect)监听 I/O 就绪事件
  • 当某个 I/O 完成,就唤醒对应协程,将其加入就绪队列准备执行
  • 按顺序或优先级调度协程,避免长时间独占 CPU

Python 3.7+ 推荐用 asyncio.run(main()) 启动,默认创建并运行一个事件循环;不再需要手动调用 get_event_loop()run_forever()

Task 和 Future 让协程真正并发起来

直接 await 协程是串行的;要并发执行多个协程,需用 asyncio.create_task() 包装成 Task:

  • Task 是协程的“调度载体”,继承Future,表示一个正在运行或等待完成的异步操作
  • Future 是底层抽象,代表“未来某个时刻会有的结果”,支持设置回调、取消、查询完成状态
  • Task 被创建后立即注册进事件循环,与其他 Task 一起被轮询调度,实现逻辑上的并行

例如:task1 = asyncio.create_task(say_after(1, "hello")) 启动后立刻返回,不阻塞后续代码;之后 await task1 才等待它结束。

await 的对象必须是“可等待的”

await 只能作用于三类对象:

  • 协程对象(async def 调用结果)
  • Task 对象(已提交到事件循环的协程)
  • Future 对象(低层异步操作的封装,如 loop.create_future()

普通函数、数字、字符串等不可 await;否则报 TypeError: object xxx can't be used in 'await' expression。判断方式:对象要有 __await__ 方法(可通过 hasattr(obj, '__await__') 检查)。

text=ZqhQzanResources