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