结构体 OwnedRwLockMappedWriteGuard

Source

pub struct OwnedRwLockMappedWriteGuard<T: ?Sized, U: ?Sized = T> { /* private fields */ }

展开描述

Owned RAII 结构，在 drop 时释放锁的独占写访问。

此结构体通过对 OwnedRwLockWriteGuard 进行 map 创建。它是一个与 OwnedRwLockWriteGuard 不同的类型，以禁止对已 map 的 guard 进行降级，因为这样做可能会导致未定义行为。

实现§

Source §

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

Source

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);

Source

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);

Source

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)));