Rust自动生成的gRPC异步方法中随机延迟的Send错误解决办法

我有一个gRPC编译器自动生成的服务端方法，用于模拟工作负载，代码如下：

async fn write(&self, request: Request<WriteRequest>)
                 -> Result<Response<WriteResponse>, Status> {
    let mut rng = rand::thread_rng();
    let random = rng.gen_range(1000..5000);
    // Sleep for the random duration
    sleep(Duration::from_millis(random)).await;
    return Ok(Response::new(WriteResponse { ... }));
}

运行时出现以下错误：

future cannot be sent between threads safely future created by async block is not `Send`

已知无法修改gRPC生成的方法签名（不能添加+Send约束），硬编码sleep时长时代码正常运行，需要解决随机数生成和随机sleep的问题。

报错原因 #

rand::thread_rng()返回的ThreadRng类型不实现Send trait，它绑定到当前线程，无法安全地在线程间传递。而gRPC服务端运行时会在不同线程间调度异步任务，要求方法返回的future必须是Send的。当async块中持有ThreadRng实例时，整个future会因为捕获了非Send类型而失去Send特性，从而触发错误。

解决方法 #

方案1：限制ThreadRng的生命周期 #

用代码块约束ThreadRng的作用范围，生成完随机数后立即销毁该实例，确保future只捕获Send安全的随机数值：

async fn write(&self, request: Request<WriteRequest>)
                 -> Result<Response<WriteResponse>, Status> {
    // 代码块内生成随机数，rng在此块结束后立即销毁
    let random = {
        let mut rng = rand::thread_rng();
        rng.gen_range(1000..5000)
    };
    
    sleep(Duration::from_millis(random)).await;
    Ok(Response::new(WriteResponse { ... }))
}

方案2：直接使用临时ThreadRng生成随机数 #

更简洁的写法：直接调用rand::thread_rng()生成随机数，不保留实例引用，临时生成的ThreadRng会在语句结束后自动销毁：

use rand::Rng;

async fn write(&self, request: Request<WriteRequest>)
                 -> Result<Response<WriteResponse>, Status> {
    let random = rand::thread_rng().gen_range(1000..5000);
    
    sleep(Duration::from_millis(random)).await;
    Ok(Response::new(WriteResponse { ... }))
}

方案3：使用全局随机数生成器（可选） #

如果不想手动管理ThreadRng，可以用rand提供的全局接口生成随机数，自行计算目标范围：

async fn write(&self, request: Request<WriteRequest>)
                 -> Result<Response<WriteResponse>, Status> {
    // 生成1000-4999之间的随机数
    let random = rand::random::<u64>() % 4000 + 1000;
    
    sleep(Duration::from_millis(random)).await;
    Ok(Response::new(WriteResponse { ... }))
}

内容的提问来源于stack exchange，提问作者Frederick Álvarez