在 Rust 中,VecDeque 并不是线程安全的
使用 Mutex 或 RwLock 包装 VecDeque:
你可以使用 std::sync::Mutex 或 std::sync::RwLock 来保护对 VecDeque 的访问。这样,在任何时候只有一个线程可以访问 VecDeque。
use std::collections::VecDeque; use std::sync::{Arc, Mutex}; use std::thread; let vec_deque = Arc::new(Mutex::new(VecDeque::new())); let vec_deque_clone = Arc::clone(&vec_deque); let handle = thread::spawn(move || { let mut deque = vec_deque_clone.lock().unwrap(); deque.push_back(1); }); handle.join().unwrap(); 在这个例子中,我们使用 Mutex 来保护 VecDeque,并在多个线程之间共享它。当一个线程锁定 VecDeque 时,其他线程必须等待,直到锁被释放。
使用通道(channel):
另一种处理并发访问的方法是使用 Rust 的通道(channel)。通道允许你在不同的线程之间发送消息,而不需要直接共享数据。这可以避免竞争条件和死锁。
use std::collections::VecDeque; use std::thread; let (tx, rx) = std::sync::mpsc::channel(); let vec_deque = Arc::new(VecDeque::new()); let vec_deque_clone = Arc::clone(&vec_deque); let handle = thread::spawn(move || { let mut deque = vec_deque_clone.lock().unwrap(); deque.push_back(1); tx.send(()).unwrap(); }); rx.recv().unwrap(); 在这个例子中,我们使用通道在两个线程之间发送消息。当一个线程完成对 VecDeque 的操作后,它会发送一个消息到通道。主线程在接收到消息后,可以继续执行其他操作。
总之,处理 VecDeque 的并发访问需要确保在同一时间只有一个线程可以访问数据。你可以使用 Mutex 或 RwLock 来保护数据,或者使用通道在不同的线程之间发送消息。