Python协程调度核心是单线程事件循环,本质为任务调度器与I/O多路复用驱动器,通过协作式调度在await点切换Task;Task是调度基本单位,需显式创建并入队,调度依赖ready、delayed和selector三类队列协同。

Python协程的调度核心是事件循环(Event Loop),它决定哪个协程在何时运行、如何挂起与恢复、怎样响应I/O就绪或定时器触发。理解其调度机制,关键不在“写协程”,而在“协程怎么被跑起来”。
事件循环是调度中枢,不是自动运行的后台线程
asyncio.get_event_loop() 或 asyncio.run() 启动的事件循环,本质是一个单线程上的**任务调度器+I/O多路复用驱动器**。它不并发执行协程,而是通过协作式调度(cooperative scheduling)在协程之间快速切换——前提是协程主动让出控制权(如 await 一个可等待对象)。
- 没有 await 的 async 函数只是普通协程对象,不会自动加入调度;必须通过 create_task()、ensure_future() 或直接 await 才进入事件循环的任务队列
- 事件循环本身不开启新线程;asyncio.to_thread() 或 loop.run_in_executor() 才会真正调用线程池
- 同一个线程内只能有一个正在运行的事件循环(除非使用 asyncio.new_event_loop() 显式创建并手动 set_event_loop)
任务(Task)是调度的基本单位,协程只是“原料”
协程(coroutine object)不可直接调度;asyncio 将其包装为 Task 对象后,才具备生命周期管理能力(如 cancel()、done()、get_coro())。Task 继承自 Future,因此天然支持回调、状态跟踪和结果获取。
- create_task(coro) 立即将协程封装为 Task 并排入“待运行队列”(ready queue),下一轮循环迭代就会尝试执行
- await coro 是同步等待:当前协程暂停,直到目标协程完成;不产生并发,也不创建 Task
- Task 一旦被 cancel(),会在下一个 await 点抛出 CancelledError;若协程正在执行 CPU 密集操作且无 await,无法被及时中断
调度顺序取决于“就绪队列”与“延迟队列”的协同
事件循环内部维护多个优先级队列:
立即学习“Python免费学习笔记(深入)”;
- Ready 队列:存放已唤醒、可立即执行的 Task(例如刚被回调唤醒、或 await 返回后恢复);FIFO 调度,但受 task.cancel() 和 task.done() 影响
- Delayed 队列(heapq):按超时时间排序的定时任务(如 asyncio.sleep(1)、loop.call_later);每次循环迭代前检查是否到期,到期则移入 ready 队列
- Selector 事件队列:由底层 select/epoll/kqueue 返回的 I/O 就绪文件描述符,对应 await 了 StreamReader.read()、asyncio.open_connection() 等的 Task 被唤醒
一次循环迭代(loop.run_once())流程:检查 delayed → 处理 I/O 就绪 → 执行 ready 队列中的 Task 直到为空 → 若无任务且无 pending callback,则阻塞等待 I/O 或超时。
手动控制调度节奏:run_until_complete 与 run_forever 的区别
asyncio.run(coro) 是高层封装:新建 loop → run_until_complete(coro) → close loop。而 run_until_complete 只运行到指定协程返回,之后 loop 停止;run_forever 则持续运行,需显式调用 loop.stop() 终止。
- run_until_complete 适合短生命周期脚本;它会在协程结束后自动清理所有未完成 Task(默认 cancel_remaining=True)
- run_forever 更接近服务器模型(如 web 服务),需自行管理 Task 生命周期,避免内存泄漏
- 在调试中可用 loop.set_debug(True) 查看 Task 创建/取消堆栈、慢回调警告、执行时间过长提示
协程调度不是魔法,它是明确的队列操作 + 条件唤醒 + 单线程协作。掌握 ready/delayed/selector 三类队列的作用,就能预判 await 后谁先跑、sleep 为何准时、为什么没 await 的协程会卡死整个循环。










