能否克隆Future以实现通用异步重试逻辑？

核心结论 #

• 绝大多数情况下不能直接克隆未启动的Future实例实现重试，和你是否能克隆它的关联参数没有直接关系，原因如下：
  • 你对Future是「函数+参数」组合的认知属于抽象层面的理解，但Rust中的Future本质是状态机：只要你拿到的是已经构造完成的Future实例，它本身就是可被轮询的状态对象，一旦第一次被.await触发过哪怕一次轮询，内部状态就会发生不可逆变更。即使它实现了Clone trait，克隆出的副本也会携带已运行过的状态，并非全新的未启动实例。
  • 即便你能保证所持有的Future从未被轮询过，绝大多数标准库、第三方库生成的Future默认都没有实现Clone trait，你无法直接调用.clone()方法复制实例。
• 你不想在每处调用点用闭包包裹重建Future的需求有成熟的通用实现方案，不需要手动在每个调用位置编写重复的闭包逻辑：
  你可以封装通用的重试工具函数，参数直接接收返回Future的闭包，由重试逻辑内部负责调用闭包生成全新的Future实例。调用侧仅需要把原来直接传Future的写法调整为传闭包即可，示例代码如下：

  use std::future::Future;
  use std::time::Duration;
  use tokio::time::sleep;
  
  /// 通用重试函数
  /// @param f: 生成需要重试的Future的闭包
  /// @param max_retries: 最大重试次数
  async fn retry<F, Fut, T, E>(mut f: F, max_retries: u32) -> Result<T, E>
  where
      F: FnMut() -> Fut,
      Fut: Future<Output = Result<T, E>>,
  {
      let mut current_retry = 0;
      loop {
          match f().await {
              Ok(result) => return Ok(result),
              Err(err) if current_retry < max_retries => {
                  current_retry += 1;
                  // 可根据需求调整退避策略，此处为简单的线性退避
                  sleep(Duration::from_millis(100 * current_retry as u64)).await;
              }
              Err(err) => return Err(err),
          }
      }
  }
  

  调用侧的代码改动极小：原来的调用写法为your_async_func(param1, param2, param3).await，调整为retry(|| your_async_func(param1, param2, param3), 3).await即可，不需要每个调用位置单独实现重试逻辑。
• 如果你坚持要避免使用闭包，仅有一种场景可以实现需求：你自定义实现了Clone trait的Future类型，保证它的所有内部存储都是生成全新Future需要的原始参数、不包含任何运行时状态，同时手动实现Future trait时每次轮询都用原始参数重新执行逻辑。但这种实现方式复杂度极高，不符合Rust Future的常规设计规范，性能开销也远大于闭包方案，不推荐使用。

内容的提问来源于stack exchange，提问作者zino