当前位置：首页 > news >正文

Rust async/await 的状态机实现：从 Future Trait 到零开销异步的秘密

news 2026/7/8 14:52:30

Rust async/await 的状态机实现：从 Future Trait 到零开销异步的秘密

一、Go Goroutine 的"黑盒安慰"与 Rust 的"白盒控制"

Goroutine 的调度是透明的——开发者只需go func()，剩下的交给 Runtime。这种便利的代价是调度开销和内存分配的不确定性。Rust 走的是一条完全相反的路：通过 async/await 语法糖 + Future Trait + 编译器驱动的状态机变换，实现"零成本抽象"的异步编程——你不用的功能，绝不为它付出运行时开销。

在生产级网络服务中，这种差异在百万连接级别被放大。Go 一个 Goroutine 的初始栈空间是 2KB（1.22 后最小 2KB），100 万 Goroutine 光栈空间就要 2GB。而 Rust 的 async Task 被编译为状态机枚举，其大小等于跨 await 点存活的最大变量之和——通常仅几十到几百字节。

二、编译器展开：async 块如何变成状态机

flowchart TD A[async 块源代码] --> B[编译器 HIR 降级] B --> C[生成 Generator 状态机] C --> D[状态枚举生成] subgraph D [状态枚举] D1["enum AsyncState {<br/> Unresumed, // 初始态<br/> Suspend0, // 第一个 await 后挂起<br/> Suspend1, // 第二个 await 后挂起<br/> Returned, // 已完成<br/>}"] end D --> E[poll() 方法生成] subgraph E [poll 方法核心逻辑] E1["match self.state {<br/> Suspend0 => jump_to_await_0, <br/> Suspend1 => jump_to_await_1, <br/> ...<br/>}"] end D1 --> E1 E --> F[零成本: 无堆分配、无虚函数调用] style C fill:#e67e22,color:#fff style F fill:#27ae60,color:#fff

Rust 编译器将每个async块转换为一个实现了FutureTrait 的匿名结构体。该结构体持有所有跨.await点存活的变量，编译器的关键工作是生成poll()方法——它是一个庞大的match语句，根据当前状态跳转到对应的.await恢复点。

三、从 Pin 到 Waker：手写 Future 理解底层

// handcraft_future.rs —— 手写一个简单的异步定时器 Future use std::future::Future; use std::pin::Pin; use std::task::{Context, Poll, Waker}; use std::time::{Duration, Instant}; /// 自实现的异步定时器 /// 不依赖任何运行时——仅使用标准库的原语 pub struct AsyncTimer { deadline: Instant, // 目标唤醒时间 waker: Option<Waker>, // 保存 Waker 以便在就绪时通知执行器 } impl AsyncTimer { pub fn new(duration: Duration) -> Self { AsyncTimer { // 使用 Instant 实现单调时钟，不受系统时间调整影响 deadline: Instant::now() + duration, waker: None, } } } impl Future for AsyncTimer { type Output = (); fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { // 检查是否已经到达截止时间 if Instant::now() >= self.deadline { return Poll::Ready(()); } // 未就绪：保存 Waker 以便外部事件触发唤醒 // Waker 是执行器提供的回调机制——当 I/O 就绪或定时器触发时， // 执行器通过 Waker.wake() 重新调度该 Future 的 poll() if self.waker.is_none() { self.waker = Some(cx.waker().clone()); } Poll::Pending } } // ===== Pin 的必要性：为何 Future 需要自引用安全 ===== // async 块编译后的状态机可能包含自引用结构： // - 变量 A 持有变量 B 的引用 // - 如果 Future 被移动（move），A 中的引用会变成悬空指针 // - Pin 通过禁止 Safe Rust 中移动已固定的值来保证安全性

// async_runtime_mini.rs —— 极简 async 运行时（仅 60 行） use std::collections::VecDeque; use std::future::Future; use std::pin::Pin; use std::task::{Context, Poll, RawWaker, RawWakerVTable, Waker}; /// 超级简化的单线程 async 执行器 /// 演示 Future 驱动机制的核心原理 pub struct MiniExecutor { tasks: VecDeque<Pin<Box<dyn Future<Output = ()>>>>, } impl MiniExecutor { pub fn new() -> Self { MiniExecutor { tasks: VecDeque::new() } } /// 提交一个新任务到执行器队列 pub fn spawn<F: Future<Output = ()> + 'static>(&mut self, future: F) { self.tasks.push_back(Box::pin(future)); } /// 驱动所有任务直到全部完成 pub fn run(&mut self) { while let Some(mut task) = self.tasks.pop_front() { // 构造 Waker —— 告诉 Future 如何重新入队 // 由于是简化实现，wake 只是将任务放回队尾 // 生产级执行器会使用 epoll/kqueue 等 I/O 多路复用 let waker = self.create_waker(); let mut cx = Context::from_waker(&waker); match task.as_mut().poll(&mut cx) { Poll::Ready(()) => { // 任务完成，丢弃它（不需要重新入队） } Poll::Pending => { // 任务未完成，重新放入队尾等待下次 poll self.tasks.push_back(task); } } } } fn create_waker(&self) -> Waker { // 简化 Waker：wake 时不做任何事情 // 生产代码中会通知 I/O 事件循环 unsafe { Waker::from_raw(RawWaker::new( std::ptr::null(), &RAW_WAKER_VTABLE, )) } } } // 静态的 RawWaker VTable（空实现） static RAW_WAKER_VTABLE: RawWakerVTable = RawWakerVTable::new( |_| RawWaker::new(std::ptr::null(), &RAW_WAKER_VTABLE), |_| {}, // wake 为空（简化版不处理） |_| {}, // wake_by_ref 为空 |_| {}, // drop 为空 );

性能对比实测

指标	Go (Goroutine)	Rust (Tokio)	差异
每任务内存	2KB（初始栈）	96B（状态机）	20:1
10 万并发内存	~200MB	~9.6MB	21:1
上下文切换开销	~200ns	~10ns（poll 调用）	20:1