结构体 MutexGuard

Source

pub struct MutexGuard<'a, T: ?Sized> { /* private fields */ }

展开描述

持有的 Mutex 的句柄。由于实现了 Send，可以在任意 .await 点持有该 guard。

只要你持有此 guard，就拥有对底层 T 的独占访问权。 guard 内部借用 Mutex，因此只要 guard 存在， mutex 就不会被丢弃。

无论 guard 何时被丢弃， lock 都会自动释放，此时 lock 将再次成功。

实现§

Source §

impl<'a, T: ?Sized> MutexGuard<'a, T>

Source

pub fn map<U, F>(this: Self, f: F) -> MappedMutexGuard<'a, U>
where U: ?Sized, F: FnOnce(&mut T) -> &mut U,

为已锁定数据的一个组件创建一个新的 MappedMutexGuard。

该操作不会失败，因为传入的 MutexGuard 已经锁定了这个互合。

这是一个关联函数，需要作为 MutexGuard::map(...) 使用。如果用方法会和已锁定数据内容器上同名的方法冲突。

§示例

use tokio::sync::{Mutex, MutexGuard};

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
struct Foo(u32);

let foo = Mutex::new(Foo(1));

{
    let mut mapped = MutexGuard::map(foo.lock().await, |f| &mut f.0);
    *mapped = 2;
}

assert_eq!(Foo(2), *foo.lock().await);

Source

pub fn try_map<U, F>(this: Self, f: F) -> Result<MappedMutexGuard<'a, U>, Self>
where U: ?Sized, F: FnOnce(&mut T) -> Option<&mut U>,

尝试为已锁定数据的一个组件创建一个新的 MappedMutexGuard。如果闭包返回 None，则返回原始的 guard。

该操作不会失败，因为传入的 MutexGuard 已经锁定了这个互合。

这是一个关联函数，需要作为 MutexGuard::try_map(...) 使用。如果用方法会和已锁定数据内容器上同名的方法冲突。

§示例

use tokio::sync::{Mutex, MutexGuard};

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
struct Foo(u32);

let foo = Mutex::new(Foo(1));

{
    let mut mapped = MutexGuard::try_map(foo.lock().await, |f| Some(&mut f.0))
        .expect("should not fail");
    *mapped = 2;
}

assert_eq!(Foo(2), *foo.lock().await);

Source

pub fn mutex(this: &Self) -> &'a Mutex<T>

返回原始 Mutex 的引用。

use tokio::sync::{Mutex, MutexGuard};

async fn unlock_and_relock<'l>(guard: MutexGuard<'l, u32>) -> MutexGuard<'l, u32> {
    println!("1. contains: {:?}", *guard);
    let mutex = MutexGuard::mutex(&guard);
    drop(guard);
    let guard = mutex.lock().await;
    println!("2. contains: {:?}", *guard);
    guard
}