示例

让我们看看 ArcMutex 的实际效果:

  1. use std::thread;
  2. // use std::sync::{Arc, Mutex};
  3. fn main() {
  4. let v = vec![10, 20, 30];
  5. let handle = thread::spawn(|| {
  6. v.push(10);
  7. });
  8. v.push(1000);
  9. handle.join().unwrap();
  10. println!("v: {v:?}");
  11. }

可能有用的解决方案:

  1. use std::sync::{Arc, Mutex};
  2. use std::thread;
  3. fn main() {
  4. let v = Arc::new(Mutex::new(vec![10, 20, 30]));
  5. let v2 = Arc::clone(&v);
  6. let handle = thread::spawn(move || {
  7. let mut v2 = v2.lock().unwrap();
  8. v2.push(10);
  9. });
  10. {
  11. let mut v = v.lock().unwrap();
  12. v.push(1000);
  13. }
  14. handle.join().unwrap();
  15. println!("v: {v:?}");
  16. }

值得注意的部分:

  • ArcMutex 中都封装了 v,因为它们的关注点是正交的。
    • Mutex 封装在 Arc 中是一种在线程之间共享可变状态的常见模式。
  • v: Arc<_> 必须先克隆为 v2,然后才能移动到另一个线程中。请注意,lambda 签名中添加了 move
  • 我们引入了块,以尽可能缩小 LockGuard 的作用域。