Linux环境下Rust并发编程如何实现

在Linux环境下，用Rust写并发代码，其实有好几条路可以走。下面逐一看看，每种方式都配了完整的代码示例，方便直接上手。 1. **线程**：最基础的手段——Rust标准库里的`std::thread`模块，拿来就能用。创建一个线程，让它跑一段闭包，然后`join`一下等它结束。简单干净，适合任务分离但不共享太多数据的场景。 ```rust use std::thread; fn main() { let handle = thread::spawn(|| { // 这里是线程执行的代码 println!("Hello from a thread!"); }); // 等待线程结束 handle.join().unwrap(); } ``` 2. **消息传递**：如果想让线程之间安全地交换数据，Rust提供了`std::sync::mpsc`——多生产者单消费者通道。一个线程发消息，另一个线程收消息，天然避免数据竞争。 ```rust use std::sync::mpsc; use std::thread; fn main() { let (tx, rx) = mpsc::channel(); thread::spawn(move || { let val = String::from("hi"); tx.send(val).unwrap(); }); let received = rx.recv().unwrap(); println!("Got: {}", received); } ``` 3. **锁**：当多个线程需要共享同一个可变数据时，`Mutex`和`RwLock`就派上用场了。配合`Arc`（原子引用计数）来跨线程共享，是经典模式。下面的例子用10个线程并发累加一个计数器，结果对得整整齐齐。 ```rust use std::sync::{Arc, Mutex}; use std::thread; fn main() { let counter = Arc::new(Mutex::new(0)); let mut handles = vec![]; for _ in 0..10 { let counter = Arc::clone(&counter); let handle = thread::spawn(move || { let mut num = counter.lock().unwrap(); *num += 1; }); handles.push(handle); } for handle in handles { handle.join().unwrap(); } println!("Result: {}", *counter.lock().unwrap()); } ``` 4. **异步编程**：如果任务偏I/O密集型，比如同时处理大量网络连接，那异步模型就比线程更轻量。Rust的`async`/`await`语法加上`tokio`运行时，能写出高性能的非阻塞代码。下面是一个简单的TCP回显服务器，每个连接由`tokio::spawn`生成一个异步任务处理。 ```rust // 需要在Cargo.toml中添加tokio依赖 // [dependencies] // tokio = { version = "1", features = ["full"] } use tokio::net::TcpListener; use tokio::prelude::*; #[tokio::main] async fn main() -> Result<(), Box> { let listener = TcpListener::bind("127.0.0.1:8080").await?; loop { let (mut socket, _) = listener.accept().await?; tokio::spawn(async move { let mut buf = [0; 1024]; // 在循环中读取数据 loop { let bytes_read = match socket.read(&mut buf).await { Ok(n) if n == 0 => return, Ok(n) => n, Err(e) => { eprintln!("Failed to read from socket: {:?}", e); return; } }; // 将数据回显给客户端 if let Err(e) = socket.write_all(&buf[0..bytes_read]).await { eprintln!("Failed to write to socket: {:?}", e); return; } } }); } } ``` 5. **Actor模型**：如果需要更高级的并发抽象，可以试试`actix`这类Actor框架。每个Actor是一个独立的计算单元，通过消息传递通信，天然隔离状态，适合搭建复杂的分布式或事件驱动系统。 选择哪种并发模型，完全取决于你的具体需求和应用场景。好的一点是，Rust通过所有权和生命周期的概念，从根本上保证了并发安全——编译期就能帮你拦住数据竞争，让你写并发代码时心里踏实很多。