事件循环通过_ready队列调度Task,协程需显式创建Task或await才执行;asyncio.sleep(0)注册回调实现让权;I/O与定时器由selector和最小堆协同处理。

asyncio 事件循环怎么拿到待执行的协程
协程对象本身不会自动运行,必须被显式调度进事件循环。当你调用 asyncio.create_task() 或 loop.create_task(),实际是把协程对象包装成 Task 实例,并调用 task._schedule_callbacks() 把它塞进事件循环的就绪队列(loop._ready,类型为 collections.deque)。直接 await coro 则由当前正在运行的 Task 自行驱动子协程,不经过就绪队列。
常见误区:以为 async def 函数一定义就入队 —— 实际上只是生成协程对象,和 lambda 类似,不调用就不触发。
-
asyncio.run(main())内部会新建事件循环、调用loop.run_until_complete(main()),再启动调度 - 手动获取当前循环用
asyncio.get_running_loop();跨线程必须用asyncio.get_event_loop_policy().get_event_loop() - 如果在非协程函数里误调
await,会报RuntimeError: await outside async function
Task 状态切换和 yield 控制点在哪
每个 Task 是一个特殊的 Future 子类,内部持有一个协程对象和状态机(_state 字段)。它只在明确的挂起点让出控制权:即遇到 await 表达式且右侧是一个“可等待对象”(Awaitable),比如另一个协程、asyncio.sleep()、asyncio.Lock 或底层 Future。
关键点在于:不是所有 await 都导致切换;如果被 await 的对象已就绪(如已完成的 Future),则立即返回结果,不交还控制权给事件循环。
立即学习“Python免费学习笔记(深入)”;
- 挂起时,Task 把自身从运行中移除,注册回调到被 await 的对象上(如
future.add_done_callback()) - 恢复时,事件循环从
loop._ready取出 Task 并调用其_step()方法继续执行协程帧 -
asyncio.current_task()返回当前正在运行的 Task 对象,可用于调试或上下文追踪
为什么 asyncio.sleep(0) 能让出执行权
asyncio.sleep(0) 创建一个将在“下一个事件循环迭代”完成的 Future,它内部调用 loop.call_soon() 注册回调,因此当前 Task 必然在本次迭代结束前被暂停,并在下一轮从 loop._ready 中重新取出执行。
这常被用作协作式让权(cooperative yielding),类似其他语言的 yield,但要注意:它不保证其他 Task 立即运行 —— 如果 loop._ready 为空,事件循环可能直接进入 I/O 等待,直到有新事件唤醒。
- 不要用
asyncio.sleep(0)模拟忙等待,它无法替代time.sleep() - 真正需要强制切出时,更推荐
await asyncio.yield_()(Python 3.12+) - 在 CPU 密集型协程中,仅靠
sleep(0)不足以避免阻塞,仍需配合loop.run_in_executor()
事件循环如何处理 I/O 和定时器
CPython 默认使用 selectors 模块实现多路复用(Linux 上是 epoll,macOS 是 kqueue),事件循环在每次迭代开始前调用 selector.select(timeout) 等待就绪的文件描述符。同时维护一个最小堆(heapq)管理定时器(loop._scheduled),每次迭代检查堆顶是否到期。
调度顺序是:先运行 loop._ready 中所有就绪 Task;再处理已到期的定时器(如 call_later);最后做一次 I/O 等待。这个三阶段循环构成一次完整的事件循环迭代。
- 如果你看到协程响应延迟,优先检查是否有长期未返回的同步代码阻塞了整个循环
-
loop.set_debug(True)会启用慢回调检测(如单次回调 > 100ms),并记录 Task 生命周期 - 自定义事件循环策略(如
uvloop)替换默认实现时,必须确保其create_future()和create_task()行为兼容 asyncio 协议
协程调度不是魔法,它依赖精确的状态跟踪与回调注册;最易忽略的是:Task 的生命周期完全由事件循环管理,一旦创建就必须被循环驱动,否则协程对象会泄漏且永不执行。调试时优先看 asyncio.all_tasks() 和 task.get_coro(),而不是只盯着 await 语句本身。










