结构体 OwnedRwLockReadGuard

Source

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

展开描述

Owned RAII 结构，在 drop 时释放锁的共享读访问。

此结构体由 RwLock 的 read_owned 方法创建。

实现§

Source §

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

Source

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

为已锁定数据的一个组件创建一个新的 OwnedRwLockReadGuard。该操作不会失败，因为传入的 OwnedRwLockReadGuard 已经锁定了这些数据。

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

§示例

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

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

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

let guard = lock.read_owned().await;
let guard = OwnedRwLockReadGuard::map(guard, |f| &f.0);

assert_eq!(1, *guard);

Source

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

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

该操作不会失败，因为传入的 OwnedRwLockReadGuard 已经锁定了这些数据。

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

§示例

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

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

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

let guard = lock.read_owned().await;
let guard = OwnedRwLockReadGuard::try_map(guard, |f| Some(&f.0)).expect("should not fail");

assert_eq!(1, *guard);

Source

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

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

§示例

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

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

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

let guard = lock.clone().read_owned().await;
assert!(Arc::ptr_eq(&lock, OwnedRwLockReadGuard::rwlock(&guard)));

let guard = OwnedRwLockReadGuard::map(guard, |f| &f.0);
assert!(Arc::ptr_eq(&lock, OwnedRwLockReadGuard::rwlock(&guard)));