结构体 OwnedMutexGuard 

pub struct OwnedMutexGuard<T: ?Sized> { /* private fields */ }

持有的 Mutex 的 owned 句柄。

此 guard 仅在 Arc 包装的 Mutex 中可用。 它与 MutexGuard 相同， 只是 它 克隆 Arc， 增加引用计数， 而不是 借用 Mutex。 这意味着 与 MutexGuard 不同， 它将具有 'static 生命周期。

只要你持有 此 guard， 就拥有 对底层 T 的独占访问权。 guard 内部 保留 指向 原始 Mutex 的 引用计数指针， 因此 即使 lock 被丢弃， guard 仍然有效。

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

实现

impl<T: ?Sized> OwnedMutexGuard<T>

pub fn map<U, F>(this: Self, f: F) -> OwnedMappedMutexGuard<T, U>

where U: ?Sized, F: FnOnce(&mut T) -> &mut U,

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

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

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

示例

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

use std::sync::Arc;



#[derive(Debug, Clone, Copy, PartialEq, Eq)]

struct Foo(u32);



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



{

    let mut mapped = OwnedMutexGuard::map(foo.clone().lock_owned().await, |f| &mut f.0);

    *mapped = 2;

}



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

pub fn try_map<U, F>( this: Self, f: F, ) -> Result<OwnedMappedMutexGuard<T, U>, Self>

where U: ?Sized, F: FnOnce(&mut T) -> Option<&mut U>,

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

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

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

示例

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

use std::sync::Arc;



#[derive(Debug, Clone, Copy, PartialEq, Eq)]

struct Foo(u32);



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



{

    let mut mapped = OwnedMutexGuard::try_map(foo.clone().lock_owned().await, |f| Some(&mut f.0))

        .expect("should not fail");

    *mapped = 2;

}



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

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

返回原始 Arc<Mutex> 的引用。

use std::sync::Arc;

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



async fn unlock_and_relock(guard: OwnedMutexGuard<u32>) -> OwnedMutexGuard<u32> {

    println!("1. contains: {:?}", *guard);

    let mutex: Arc<Mutex<u32>> = OwnedMutexGuard::mutex(&guard).clone();

    drop(guard);

    let guard = mutex.lock_owned().await;

    println!("2. contains: {:?}", *guard);

    guard

}

Trait 实现

impl<T: ?Sized + Debug> Debug for OwnedMutexGuard<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

使用给定的格式化器格式化此值。 更多信息

impl<T: ?Sized> Deref for OwnedMutexGuard<T>

type Target = T

解引用后得到的类型。

fn deref(&self) -> &Self::Target

解引用此值。

impl<T: ?Sized> DerefMut for OwnedMutexGuard<T>

fn deref_mut(&mut self) -> &mut Self::Target

以可变方式解引用此值。

impl<T: ?Sized + Display> Display for OwnedMutexGuard<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

使用给定的格式化器格式化此值。 更多信息

impl<T: ?Sized> Drop for OwnedMutexGuard<T>

fn drop(&mut self)

执行此类型的析构函数。 更多信息

impl<T> Sync for OwnedMutexGuard<T>

where T: ?Sized + Send + Sync,