面试题：Rust异步通道基础使用

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

#[tokio::main]
async fn main() {
    // 创建异步通道，返回一个发送者和一个接收者
    let (tx, rx) = mpsc::channel(10);

    // 启动一个异步任务来发送数据
    task::spawn(async move {
        let data = "Hello, Channel!";
        // 使用发送者的send方法发送数据，send方法是异步的，所以这里使用await等待发送完成
        if let Err(e) = tx.send(data).await {
            eprintln!("发送数据失败: {}", e);
        }
    });

    // 在主异步任务中接收数据
    if let Some(received) = rx.recv().await {
        println!("接收到数据: {}", received);
    } else {
        println!("通道已关闭");
    }
}

在这段代码中：

async 关键字用于定义异步函数或异步块。异步函数返回一个实现了 Future 特征的值，它允许函数暂停执行并将控制权交回给调用者，直到某个异步操作完成。在 main 函数前使用 async 表明这是一个异步入口点，并且在新启动的异步任务的闭包前也使用 async。
await 关键字用于暂停异步函数的执行，直到其所等待的 Future 完成。在发送数据 tx.send(data).await 和接收数据 rx.recv().await 时使用 await，这样当前异步任务会暂停，直到数据成功发送或接收到数据。
channel 相关方法：
- mpsc::channel(10) 创建了一个异步多生产者单消费者通道，10 是通道的缓冲区大小。返回值是一个元组，包含一个发送者 tx 和一个接收者 rx。
- tx.send(data) 方法用于将数据发送到通道中，它返回一个 Future，所以需要使用 await 等待发送操作完成。
- rx.recv() 方法用于从通道中接收数据，同样返回一个 Future，需要 await 等待直到有数据可接收或者通道关闭。

面试题：Rust异步通道基础使用

知识考点

面试题答案