结构体 OwnedRwLockMappedWriteGuard

源代码

pub struct OwnedRwLockMappedWriteGuard<T: ?Sized, U: ?Sized = T> { /* 私有字段 */ }

展开描述

用于在 drop 时释放锁的独占写访问权的 owned RAII 结构。

此结构体通过对 OwnedRwLockWriteGuard 进行映射创建。它是与 OwnedRwLockWriteGuard 分开的类型，因为降级映射后的 guard 可能导致未定义行为，因此不允许这样做。

实现§

源代码 §

impl<T: ?Sized, U: ?Sized> OwnedRwLockMappedWriteGuard<T, U>

源代码

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

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

此操作不会失败，因为传入的 OwnedRwLockMappedWriteGuard 已经锁定了数据。

这是一个关联函数，需要以 OwnedRwLockWriteGuard::map(..) 的方式使用。如果使用方法，将与已锁定数据内容上同名的方法产生冲突。

§示例

use std::sync::Arc;
use tokio::sync::{RwLock, OwnedRwLockWriteGuard};

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

let lock = Arc::new(RwLock::new(Foo(1)));

{
    let lock = Arc::clone(&lock);
    let mut mapped = OwnedRwLockWriteGuard::map(lock.write_owned().await, |f| &mut f.0);
    *mapped = 2;
}

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

源代码

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

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

此操作不会失败，因为传入的 OwnedRwLockMappedWriteGuard 已经锁定了数据。

这是一个关联函数，需要用作 OwnedRwLockMappedWriteGuard::try_map(...)。方法会与锁定数据内容上的同名方法冲突。

§示例

use std::sync::Arc;
use tokio::sync::{RwLock, OwnedRwLockWriteGuard};

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

let lock = Arc::new(RwLock::new(Foo(1)));

{
    let guard = Arc::clone(&lock).write_owned().await;
    let mut guard = OwnedRwLockWriteGuard::try_map(guard, |f| Some(&mut f.0)).expect("should not fail");
    *guard = 2;
}

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

源代码

pub fn rwlock(this: &Self) -> &Arc<RwLock<T>>

返回对原始 Arc<RwLock> 的引用。

§示例

use std::sync::Arc;
use tokio::sync::{
    RwLock,
    OwnedRwLockWriteGuard,
    OwnedRwLockMappedWriteGuard,
};

let lock = Arc::new(RwLock::new(1));

let guard = lock.clone().write_owned().await;
let guard = OwnedRwLockWriteGuard::map(guard, |x| x);
assert!(Arc::ptr_eq(&lock, OwnedRwLockMappedWriteGuard::rwlock(&guard)));