使用线程和异步/等待时如何解决“无法返回引用本地数据的值”？

Question

我正在学习 Rust，特别是并行的多线程和异步请求。

我阅读了文档，但仍然不明白我在哪里犯了错误。我想我知道在哪里，但不知道如何解决它。

主程序.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);
    }
}

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);
    }
}

Cargo.toml

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

Answer 1

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

1. 不可变的引用
2. 可变引用
3. 按价值

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

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

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

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

也可以看看：

• `|_| 和有什么区别 异步移动 {}` 和`异步移动 |_| {}`
• 有没有办法让 Rust 闭包只将一些变量移入其中？

根据您的理解，此时您不太可能想要混合线程和异步。一种本质上是阻塞的，另一种期望代码不阻塞。您应该遵循如何使用 reqwest 执行并行异步 HTTP GET 请求？反而。

也可以看看：

• 在 future-rs 中封装阻塞 I/O 的最佳方法是什么？