README.md

title	tags
Channel 通道	Rust concurrency wtfacademy

WTF Rust 极简入门: 消息传递并发性

在 Rust 中，消息传递并发是利用通道（channels）来在多个线程之间安全地传递消息。这种方法遵循着“通过消息来共享内存，而不是通过共享内存来通信”的并发哲学。

使用通道

通道是 Rust 中用于线程间通信的主要机制，由发送者（sender）和接收者（receiver）组成。通道确保了数据传输的安全性，防止了数据竞争和其他并发错误。

创建通道

使用std::sync::mpsc模块（多生产者，单消费者），可以创建一个通道：

use std::sync::mpsc;
use std::thread;

fn main() {
    let (tx, rx) = mpsc::channel();

    thread::spawn(move || {
        let msg = String::from("Hello from the thread!");
        tx.send(msg).unwrap();
    });

    let received = rx.recv().unwrap();
    println!("Received: {}", received);
}

注意事项

1. 发送端的克隆：如果多个线程需要发送消息到同一个接收者，可以克隆发送端tx.clone()。每个发送端都可以在不同的线程中使用，但所有消息仍将发送到同一个接收端。
2. 错误处理：send方法返回Result<T, E>，如果接收端已关闭，则返回Err，需要适当处理这种情况。
3. 阻塞与非阻塞接收：recv方法阻塞当前线程直到收到消息，而try_recv不会阻塞，它立即返回Result，根据是否有消息可用来决定是Ok还是Err。

日常使用场景

• 日志系统：可以将日志信息从多个线程发送到一个日志处理线程，集中处理。
• 任务分发系统：主线程创建任务并通过通道分发给工作线程，工作线程处理完任务后，再将结果发送回主线程。
• 事件通知系统：在事件触发时，通过通道通知相关的处理线程进行相应的操作。

高级通道操作

以上基本用法之外，Rust 的通道系统还支持更复杂的操作：

多消费者模式

虽然std::sync::mpsc是多生产者单消费者模型，但你可以通过创建多个接收端和手动分配的方式管理多消费者的场景。

选择器（Selectors）

通过选择器（selectors），可以在多个接收端之间进行选择，处理第一个可用的消息。这对于优先级消息处理尤其有用，使用select!宏可以实现：

use std::sync::mpsc::{self, Select};
use std::thread;

fn main() {
    let (tx1, rx1) = mpsc::channel();
    let (tx2, rx2) = mpsc::channel();

    let sel = Select::new();
    let mut handle1 = sel.handle(&rx1);
    let mut handle2 = sel.handle(&rx2);

    unsafe {
        handle1.add();
        handle2.add();
    }

    thread::spawn(move || {
        tx1.send(1).unwrap();
    });

    thread::spawn(move || {
        tx2.send(2).unwrap();
    });

    let oper = sel.select();
    let index = oper.index();
    let result = oper.recv().unwrap();

    println!("Received {} from channel {}", result, index);
}

通过这些高级功能，可以灵活地在 Rust 程序中处理并发问题，为高效、可靠的系统设计提供强大支持。