互斥器(Mutex)

Mutex ensures mutual exclusion and allows mutable access to T behind a read-only interface (another form of interior mutability):

  1. use std::sync::Mutex;
  2. fn main() {
  3. let v = Mutex::new(vec![10, 20, 30]);
  4. println!("v: {:?}", v.lock().unwrap());
  5. {
  6. let mut guard = v.lock().unwrap();
  7. guard.push(40);
  8. }
  9. println!("v: {:?}", v.lock().unwrap());
  10. }

请注意我们如何设置 impl Sync for Mutex 通用 实现。

  • Mutex in Rust looks like a collection with just one element —- the protected data.
    • 在访问受保护的数据之前不可能忘记获取互斥量。
  • 你可以通过获取锁,从 &Mutex<T> 中获取 &mut TMutexGuard 能够确保 &mut T 存在的时间不会比持有锁的时间更长。
  • Mutex<T> implements both Send and Sync iff (if and only if) T implements Send.
  • A read-write lock counterpart: RwLock.
  • Why does lock() return a Result?
    • 如果持有 Mutex 的线程发生panic,Mutex 便会“中毒”并发出信号, 表明其所保护的数据可能处于不一致状态。对中毒的互斥量调用 lock() 将会失败, 并将显示 PoisonError。无论如何,你可以对该错误调用 into_inner() 来 恢复数据。