0

我不确定它为什么会挂起my.rw.write();。

如果您取消注释sleep呼叫，它工作正常。这意味着在 spawn 线程执行并释放RwLock. 我觉得理论上应该没问题。我哪里错了？

use std::sync::Arc;
use std::sync::RwLock;
use std::{thread, time};

struct MySt {
    num1: i64,
    num2: i64,
    rw: RwLock<Vec<i64>>,
}

fn main() {
    let my = Arc::new(MySt {
        num1: 32,
        num2: 64,
        rw: RwLock::new(vec![1, 2, 3]),
    });
    let my2 = my.clone();
    let t = thread::spawn(move || {
        let mut rw = my2.rw.write().unwrap();
        rw[0] = 5;
        println!("child thread {}, {}, {}, {}", my2.num1, my2.num2, rw[0], rw[1]);
    });
    //thread::sleep(time::Duration::from_millis(1000));
    let mut rw = my.rw.write().unwrap();
    rw[1] = 6;
    println!("main thread {}, {}, {}, {}", my.num1, my.num2, rw[0], rw[1]);
    t.join().unwrap();
}
4

2 回答 2

2

在 spawn 线程被执行并释放后，写访问尝试仍然阻塞主线程RwLock

这是不正确的。添加基本​​调试输出以区分它们表明唯一println运行的是main.

无法保证在子线程生成后哪个线程将首先执行。但是，主线程可能会继续运行，因为它已经在运行。如果是这样，它将锁定RwLock通孔rw并保持锁定直到功能结束。但是，在函数结束之前，主线程会阻塞等待子线程加入。子线程无法完成，因为它必须先获取写锁。您已经创建了一个经典的死锁。

要解决这个问题，请使用显式解锁锁drop或添加范围以限制锁的生命周期：

fn main() {
    let my = Arc::new(MySt {
        num1: 32,
        num2: 64,
        rw: RwLock::new(vec![1, 2, 3]),
    });
    let my2 = my.clone();
    let t = thread::spawn(move || {
        let mut rw = my2.rw.write().unwrap();
        rw[0] = 5;
        println!("thread a {}, {}, {}, {}", my2.num1, my2.num2, rw[0], rw[1]);
    });
    //thread::sleep(time::Duration::from_millis(1000));
    let mut rw = my.rw.write().unwrap();
    rw[1] = 6;
    println!("thread b {}, {}, {}, {}", my.num1, my.num2, rw[0], rw[1]);
    drop(rw);
    t.join().unwrap();
}

添加sleep很可能导致子线程先执行。然后它将获取锁并退出，允许主线程继续。

也可以看看：

于 2019-12-18T02:03:47.397 回答
0

它无法正常工作的原因是当主线程中的锁在子线程中的锁之前执行时我没有释放锁。我像下面一样修复了它。

use std::sync::Arc;
use std::sync::RwLock;
use std::{thread, time};

struct MySt {
    num1: i64,
    num2: i64,
    rw: RwLock<Vec<i64>>,
}

fn main() {
    let my = Arc::new(MySt {
        num1: 32,
        num2: 64,
        rw: RwLock::new(vec![1, 2, 3]),
    });
    let my2 = my.clone();
    let t = thread::spawn(move || {
        let mut rw = my2.rw.write().unwrap();
        rw[0] = 5;
        println!("child thread {}, {}, {}, {}", my2.num1, my2.num2, rw[0], rw[1]);
    });
    {
        let mut rw = my.rw.write().unwrap();
        rw[1] = 6;
        println!("main thread {}, {}, {}, {}", my.num1, my.num2, rw[0], rw[1]);
    }
    t.join().unwrap();
}
于 2019-12-18T02:05:27.367 回答