面试题：Rust异步编程之并发与阻塞处理

使用tokio实现并发请求
- 在Rust中，tokio是一个常用的异步运行时库。要同时发起多个异步网络请求并在所有请求完成后进行数据汇总处理，可以使用tokio::join!宏或者futures::future::join_all函数。
- tokio::join!宏：适用于少量固定数量的异步任务。它最多支持16个参数，每个参数都是一个异步任务。
- futures::future::join_all函数：适用于处理动态数量的异步任务。它接受一个Vec或者其他实现了IntoIterator的集合，集合中的元素是异步任务。
避免异步操作阻塞主线程
- 在Rust的异步编程模型中，异步函数内部的阻塞操作会导致问题。如果某个异步操作可能会阻塞主线程，应该确保这个操作本身是异步的，或者将阻塞操作包装在tokio::task::spawn_blocking中，这样阻塞操作会在一个单独的线程池中执行，不会阻塞主线程。

以下是使用tokio和reqwest（一个HTTP客户端库）进行并发网络请求的代码示例：

use reqwest;
use tokio;

async fn fetch_data(url: &str) -> Result<String, reqwest::Error> {
    let client = reqwest::Client::new();
    let response = client.get(url).send().await?;
    response.text().await
}

#[tokio::main]
async fn main() {
    let urls = vec![
        "https://example.com",
        "https://rust-lang.org",
        "https://github.com",
    ];

    // 使用futures::future::join_all处理动态数量的任务
    let mut tasks = urls.into_iter().map(|url| tokio::spawn(fetch_data(url)));
    let results = futures::future::join_all(tasks).await;

    let mut all_data = String::new();
    for result in results {
        match result {
            Ok(Ok(data)) => all_data.push_str(&data),
            Ok(Err(e)) => eprintln!("Error fetching data: {}", e),
            Err(e) => eprintln!("Task panicked: {}", e),
        }
    }

    println!("All data combined: {}", all_data);
}

代码解释：

fetch_data函数：使用reqwest库发起HTTP GET请求并返回响应的文本内容。这个函数是异步的，不会阻塞主线程。
main函数：定义了一个包含多个URL的Vec。
urls.into_iter().map(|url| tokio::spawn(fetch_data(url))：为每个URL创建一个异步任务。tokio::spawn将异步任务提交到tokio运行时。
futures::future::join_all(tasks).await：等待所有异步任务完成，并返回一个包含所有任务结果的Vec。
后续代码遍历任务结果，将成功获取的数据汇总到all_data字符串中，并处理可能出现的错误。

如果有潜在的阻塞操作，例如读取一个大文件，可以这样处理：

use std::fs::read_to_string;
use tokio;

async fn read_file_async(path: &str) -> Result<String, std::io::Error> {
    tokio::task::spawn_blocking(move || read_to_string(path)).await?
}

这里read_to_string是一个阻塞操作，通过tokio::task::spawn_blocking将其包装，使得它在一个单独的线程池中执行，不会阻塞异步运行时的主线程。

星途面试题库

面试题：Rust异步编程之并发与阻塞处理

知识考点

面试题答案