教程 rust tutorial

并发任务处理器

Rust 提供强大的并发机制,如线程、消息通道和异步编程模型,使其非常适合构建高效、可靠的后台任务处理器。例如:从任务队列中提取任务并并发处理。

本节演示使用线程池处理多个任务。

代码演示

Rust Playground
打开运行
use std::thread;
use std::sync::mpsc;
use std::time::Duration;

fn main() { let (sender, receiver) = mpsc::channel();

for i in 0..5 {
    let sender = sender.clone();
    thread::spawn(move || {
        println!("任务 {} 开始", i);
        thread::sleep(Duration::from_secs(1));
        sender.send(format!("任务 {} 完成", i)).unwrap();
    });
}

drop(sender); // 关闭发送端,避免阻塞

for result in receiver {
    println!("{}", result);
}

println!("所有任务处理完成");

}