Rust在Debian上的并發編程

在Debian上進行Rust并發編程，需先安裝Rust工具鏈，再選擇并發模型實現，核心步驟如下：

1. 安裝Rust

使用rustup安裝Rust，確保工具鏈包含最新穩定版：

curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh  
source $HOME/.cargo/env  # 配置環境變量  

驗證安裝：rustc --version。

2. 并發編程模型

（1）線程模型

通過std::thread創建線程，適合CPU密集型任務：

use std::thread;  
fn main() {  
    let handle = thread::spawn(|| {  
        println!("子線程執行");  
    });  
    handle.join().unwrap(); // 等待線程結束  
}  

（2）消息傳遞（通道）

利用std::sync::mpsc實現線程間通信，支持多生產者單消費者：

use std::sync::mpsc;  
use std::thread;  
fn main() {  
    let (tx, rx) = mpsc::channel();  
    thread::spawn(move || {  
        tx.send("消息內容").unwrap();  
    });  
    println!("收到: {}", rx.recv().unwrap());  
}  

（3）異步編程

基于tokio運行時，使用async/await實現高并發I/O：

1. 在Cargo.toml添加依賴：

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

2. 編寫異步代碼：

   use tokio::net::TcpListener;  
   #[tokio::main]  
   async fn main() -> Result<(), Box<dyn std::error::Error>> {  
       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];  
               if let Ok(n) = socket.read(&mut buf).await {  
                   socket.write_all(&buf[..n]).await.unwrap();  
               }  
           });  
       }  
   }  
   

（4）共享狀態同步

使用Arc（原子引用計數）+Mutex（互斥鎖）安全共享數據：

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);  
        handles.push(thread::spawn(move || {  
            let mut num = counter.lock().unwrap();  
            *num += 1;  
        }));  
    }  
    println!("最終結果: {}", *counter.lock().unwrap());  
}  

3. 注意事項

• 所有權與生命周期：Rust編譯器會嚴格檢查數據競爭，確保并發安全。
• 性能優化：根據場景選擇模型，如高并發I/O優先用異步編程，CPU密集型任務用線程或并行計算庫（如rayon）。
• 調試工具：可搭配gdb或lldb調試多線程程序，或使用tokio-console監控異步任務。

以上內容綜合自Debian環境下的Rust并發編程實踐，可根據具體需求選擇合適方案。