在 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
来保护数据,或者使用通道在不同的线程之间发送消息。