Futures

Future 是一种 trait,由表示尚未完成的操作的对象所实现。可以轮询 Future,并且 poll 会返回 一个 Poll 对象。

#![allow(unused)]
fn main() {
use std::pin::Pin;
use std::task::Context;

pub trait Future {
    type Output;
    fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>;
}

pub enum Poll<T> {
    Ready(T),
    Pending,
}
}

异步函数会返回 impl Future。对于自定义的类型,也可以实现 Future(但不常见)。例如,从 tokio::spawn 返回的 JoinHandle 会实现 Future,以允许加入该任务。

在 Future 中使用 .await 关键字会导致当前异步函数暂停,直到该 Future 准备就绪,然后计算其输出。

  • FuturePoll 类型的实现完全如下所示:请点击链接查看文档中的实现。

  • 我们的重点在于编写异步代码,而不是构建新的异步基元,因此不会涉及 PinContext。简言之:

    • 通过 Context,Future 在事件发生时可自行安排重新进行轮询。

    • Pin 确保 Future 不会移到内存中,以便指向该 Future 的指针仍然有效。为了确保使用 .await 之后引用依然有效,必须执行此操作。