为何Rust Future实现中while let可触发Waker，而if let却无法触发？

问题场景 #

我在Rust中实现一个Future时遇到了不符合预期的行为：在poll方法中使用std::sync::mpsc::Receiver的try_recv时，while let和if let的写法导致了完全不同的运行结果。

简化后的poll方法代码如下：

fn poll(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Self::Output> {
    let this = self.get_mut();

    // 选项1：工作正常
    while let Ok(new_attributes) = this.receiver.try_recv() {
        // 处理消息
    }

    // 选项2：导致Future挂起
    // if let Ok(new_attributes) = this.receiver.try_recv() {
    //     // 处理消息
    // }

    Poll::Pending
}

观察到的现象 #

• 使用while let时，Future会在新消息到达时被正常重新poll，一切功能正常。
• 使用if let时，Future会挂起，即使有新消息到达也不再被唤醒。

我的疑问 #

我知道Waker用于通知executor重新poll Future，但我的poll方法总是返回Poll::Pending，我原本以为Future会被反复poll直到进程停止。但我不理解为什么while let能确保Waker被正确触发，而if let却不行。

解答 #

首先要纠正你一个核心误解：返回Poll::Pending并不意味着executor会无限制地反复轮询这个Future。现代Rust executor（比如你使用的spawn_blocking对应的执行器）的设计是为了高效利用CPU，不会做无意义的空转——只有当Future关联的Waker被主动唤醒时，executor才会再次调度它执行poll。这是你遇到问题的关键原因。

接下来拆解两种写法的差异：

1. 为什么while let能正常触发Waker？

当你用while let Ok(...) = this.receiver.try_recv()时，会循环调用try_recv直到它返回Err（通常是通道为空）。这会带来两个关键结果：

• 你在一次poll中处理完了通道中所有可用的消息，让Future进入了真正的“等待新消息”状态。
• 无论是异步mpsc（如tokio的sync::mpsc）还是你自己封装的同步mpsc，此时都会正确注册当前Future的Waker：
  • 对于异步mpsc通道，当try_recv返回“通道为空”时，内部会自动将当前的Waker关联到通道上，后续有新消息发送时，通道会触发Waker通知executor。
  • 如果你用的是std同步mpsc，那么你大概率在发送消息的逻辑中，会主动调用这个Future的Waker来唤醒（比如发送方持有Waker引用，send后调用wake_by_ref）。

这种写法完全符合Future的正确工作流程：处理完当前所有任务→进入等待状态→注册Waker→等待唤醒后重新poll。

2. 为什么if let会导致Future挂起？

当你用if let Ok(...) = this.receiver.try_recv()时，只尝试取一次消息就直接返回Poll::Pending，这会破坏上述流程：

• Waker未被正确注册：如果是异步mpsc通道，只有当try_recv返回“通道为空”时才会触发Waker注册逻辑；你只取了一个消息就停下，通道可能还有剩余消息，或者通道状态未进入“需要唤醒”的阶段，导致Waker没被注册。
• executor停止调度：由于你返回了Poll::Pending但没有有效的Waker，executor会默认这个Future已经没有继续执行的可能，会停止对它的调度。哪怕之后有新消息进入通道，也没有机制通知executor重新poll这个Future，最终表现为Future“挂起”。

补充验证你的理解

你之前认为返回Poll::Pending就会被反复poll，这是错误的。executor只会在Waker被唤醒时才会重新调度Future，这是异步编程中避免CPU空转的核心设计。while let的写法刚好契合了这个设计的要求，而if let的写法则跳过了关键的“进入等待状态并注册Waker”的步骤。

备注：内容来源于stack exchange，提问作者narumi