使用线程时如何解决"cannot return value referencing local data"和async/await？

Question

我正在学习 Rust，尤其是并行处理多线程和异步请求。

我看了文档，还是不明白哪里出错了。我假设我知道在哪里，但不知道如何解决它。

main.rs

use std::thread;

struct Request {
    url: String,
}

impl Request {
    fn new(name: &str) -> Request {
        Request {
            url: name.to_string(),
        }
    }

    async fn call(&self, x: &str) -> Result<(), Box<dyn std::error::Error>> {
        let resp = reqwest::get(x).await;
        Ok(())
    }
}

#[tokio::main]
async fn main() {
    let requests = vec![
        Request::new("https://www.google.com/"),
        Request::new("https://www.google.com/"),
    ];
    let handles: Vec<_> = requests
        .into_iter()
        .map(|request| {
            thread::spawn(move || async {
                request.call(&request.url).await;
            })
        })
        .collect();

    for y in handles {
        println!("{:?}", y);
    }
}

error[E0515]: cannot return value referencing local data `request`
  --> src/main.rs:29:35
   |
29 |               thread::spawn(move || async {
   |  ___________________________________^
30 | |                 request.call(&request.url).await;
   | |                 ------- `request` is borrowed here
31 | |             })
   | |_____________^ returns a value referencing data owned by the current function

Cargo.toml

[dependencies]
reqwest = "0.10.4"
tokio = { version = "0.2", features = ["full"] }

Answer 1

像闭包一样，async 块尽可能弱地捕获它们的变量。按优先顺序排列：

不可变引用
可变引用
按价值

这取决于变量在闭包/异步块中的使用方式。在您的示例中，request 仅通过引用使用，因此仅通过引用捕获：

async {
    request.call(&request.url).await;
}

但是，您需要将变量的所有权转移到异步块，以便在最终执行 future 时变量仍然存在。与闭包一样，这是通过 move 关键字完成的：

thread::spawn(move || async move {
    request.call(&request.url).await;
})

另请参阅：

根据您的理解，非常不可能您想在此时混合使用线程和异步。一种本质上是阻塞的，另一种期望代码不会阻塞。您应该遵循中概述的示例。

另请参阅：

使用线程时如何解决"cannot return value referencing local data"和async/await？

How do I solve "cannot return value referencing local data" when using threads and async/await?

rust

async-await

rust-tokio

reqwest