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 准备就绪,然后计算其输出。
-
Future和Poll类型的实现完全如下所示:请点击链接查看文档中的实现。 -
我们的重点在于编写异步代码,而不是构建新的异步基元,因此不会涉及
Pin和Context。简言之:-
通过
Context,Future 在事件发生时可自行安排重新进行轮询。 -
Pin确保 Future 不会移到内存中,以便指向该 Future 的指针仍然有效。为了确保使用.await之后引用依然有效,必须执行此操作。
-