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
之后引用依然有效,必须执行此操作。
-