探究Python AsyncIO中Future对象的内部等待机制

问题背景 #

先看这段会永久阻塞的代码：

import asyncio

async def main():
    f = asyncio.Future()
    await f

asyncio.run(main())

当协程mainawait一个未完成的Future时，会被阻塞直到该Future被设置结果、异常或取消。查看tasks.py中的__step()方法，发现当result是标记了_asyncio_future_blocking == True的Future时，代码会：

1. 将result._asyncio_future_blocking设为False
2. 给Future添加__wakeup回调
3. 将self._fut_waiter指向这个Future

但这里没有看到类似self._loop.call_soon(self.__step)的调度逻辑，结合Task类的注释：

An important invariant maintained while a Task not done: #

#

- Either _fut_waiter is None, and _step() is scheduled; #

- or _fut_waiter is some Future, and _step() is not scheduled. #

#

The only transition from the latter to the former is through #

_wakeup(). When _fut_waiter is not None, one of its callbacks #

must be _wakeup(). #

有以下疑问：

• Future是否会注册到select函数中？
• 这些Future在哪里被检测、如何与事件循环交互？
• 官方AsyncIO中Future的角色是什么？

解答 #

1. Task挂起与唤醒的核心逻辑 #

当Task的__step()方法遇到未完成的Future时，它会主动放弃后续调度，因为此时self._fut_waiter已经指向了这个Future，符合注释中“_fut_waiter不为None时，_step()不被调度”的不变量。

真正的唤醒逻辑在__wakeup回调里：当Future完成（调用set_result/set_exception/被取消）时，这个回调会被触发，它内部会调用事件循环的call_soon方法，重新将Task的__step()调度到事件循环中，让Task继续执行await之后的代码。

2. Future与事件循环、select的关系 #

普通手动创建的Future（比如示例中的f）不会直接注册到select，因为它没有关联任何IO操作。只有和IO绑定的Future（比如socket的读写、网络请求返回的Future）才会被事件循环注册到select/poll/epoll等多路复用机制中：

• 当你发起一个IO异步操作时，AsyncIO会将对应的文件描述符注册到事件循环的多路复用器中；
• 事件循环会持续监听这些文件描述符的就绪状态；
• 当IO操作就绪时，事件循环会调用对应的回调函数，完成关联的Future，进而触发该Future的所有done回调（包括Task的__wakeup），唤醒等待它的Task。

而手动创建的Future，需要你主动调用set_result或set_exception来标记它完成，此时同样会触发__wakeup回调，唤醒等待它的Task。

3. Future在AsyncIO中的核心角色 #

Future是AsyncIO中异步操作结果的抽象载体，是连接协程、Task和事件循环的核心桥梁：

• 对协程/Task：它是可await的对象，协程通过await Future来等待异步操作完成，不需要关心底层是IO、定时器还是其他异步逻辑；
• 对事件循环：它是可监听的“完成信号”，事件循环通过管理Future的状态变化（从pending到done）来调度Task的执行；
• 统一异步接口：不管是IO操作、定时器、手动触发的任务，都可以封装成Future，让上层代码用统一的方式处理异步逻辑；
• 回调机制：通过add_done_callback注册的回调，是事件循环实现Task唤醒、异步逻辑串联的关键。

对比David Beazley演示的基于文件描述符的事件循环，官方AsyncIO中的Future相当于把底层的IO事件、定时器事件等都封装成了统一的Future对象，让异步编程的接口更简洁、更高层，不需要用户直接操作文件描述符。

内容的提问来源于stack exchange，提问作者S.B