0

我正在尝试声明和读/写自定义结构的实例，lazy_static因为我必须在其初始化（字符串）时使用非常量函数。

正如我在另一个 Stackoverflow 帖子中看到的，我尝试使用 RwLock，它在写入时工作正常，但在读取时失败，并出现以下错误：

thread 'main' panicked at 'rwlock read lock would result in deadlock', /Users/adrien/.rustup/toolchains/stable-x86_64-apple-darwin/lib/rustlib/src/rust/library/std/src/sys/unix/rwlock.rs:47:13
note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace

pub struct Authentication {
    access_token: String,
    refresh_token: String,
    expiration: u32
}

lazy_static! {
    static ref LATEST_AUTH: RwLock<Authentication> = RwLock::new(Authentication {
        access_token: "access".to_string(),
        refresh_token: "refresh".to_string(),
        expiration: 0
    });
}

pub fn auth(){
   let api_resp: ApiResponse = res.json().unwrap(); //From a reqwest res
   let mut au = LATEST_AUTH.write().unwrap();
   au.access_token = api_resp.access_token.clone();
   println!("LATEST_AUTH:{}", LATEST_AUTH.read().unwrap()); //Fails
}
4

1 回答 1

3

ARwLock在锁守卫的整个范围内被锁定，这是从对read()or的调用中获得的write()。

在您的情况下，写锁守卫 ,在函数au的整个持续时间内都存在。auth这就是错误的意思：您已经锁定了它，然后尝试在同一个线程中再次锁定它会使其永远阻塞。

写锁也可用于读取，因此您可以通过重新使用它而不是尝试再次锁定它来解决此问题：

pub fn auth(){
   let api_resp: ApiResponse = res.json().unwrap();
   let mut au = LATEST_AUTH.write().unwrap();
   au.access_token = api_resp.access_token.clone();
   println!("LATEST_AUTH:{}", au);
}

或者，您可以强制更快地释放锁，以便您可以锁定它以单独阅读：

pub fn auth(){
   let api_resp: ApiResponse = res.json().unwrap();
   let mut au = LATEST_AUTH.write().unwrap();
   au.access_token = api_resp.access_token.clone();
   std::mem::drop(au);
   println!("LATEST_AUTH:{}", LATEST_AUTH.read().unwrap());
}

或者：

pub fn auth(){
   let api_resp: ApiResponse = res.json().unwrap();
   // a new scope
   {
       let mut au = LATEST_AUTH.write().unwrap();
       au.access_token = api_resp.access_token.clone();
       // au will be dropped here, when it goes out of scope
   }
   println!("LATEST_AUTH:{}", LATEST_AUTH.read().unwrap());
}
于 2020-10-19T08:49:45.133 回答