面试题：Rust中异步通道的基本实现方式

代码示例：

use tokio::sync::mpsc;
use tokio::task;

#[tokio::main]
async fn main() {
    // 创建异步通道，通道容量为10
    let (tx, mut rx) = mpsc::channel(10);

    // 发送方任务
    task::spawn(async move {
        for i in 0..10 {
            if let Err(e) = tx.send(i).await {
                eprintln!("发送失败: {}", e);
            }
        }
    });

    // 接收方任务
    while let Some(val) = rx.recv().await {
        println!("接收到: {}", val);
    }
}

主要类型和函数说明：
- mpsc::channel：这是Tokio库中用于创建异步多生产者 - 单消费者（MPSC）通道的函数。它返回一个元组 (Sender, Receiver)，其中 Sender 用于发送数据，Receiver 用于接收数据。这里的 mpsc 是 “Multiple Producer, Single Consumer” 的缩写。
- Sender::send：这是 Sender 类型的方法，用于向通道发送数据。它返回一个 Result，如果发送成功，Result 为 Ok(())；如果通道关闭或者发生错误，Result 为 Err。
- Receiver::recv：这是 Receiver 类型的方法，用于从通道接收数据。它返回一个 Option，如果接收到数据，Option 为 Some(T)，其中 T 是发送的数据类型；如果通道关闭且没有更多数据，Option 为 None。
- task::spawn：Tokio库中的函数，用于在Tokio运行时中创建一个新的异步任务。这里我们用它来并发地运行发送方任务。

注意：在实际应用中，tokio::sync::mpsc 所在的Tokio库需要在 Cargo.toml 文件中添加依赖。示例如下：

[dependencies]
tokio = { version = "1", features = ["full"] }

上述代码基于Tokio库，在Rust中实现了一个简单的异步通道用于不同异步任务间传递数据。

星途面试题库

面试题：Rust中异步通道的基本实现方式

知识考点

面试题答案