跳到主要内容

OwnedMutexGuard

搜索

结构体 OwnedMutexGuard 

源代码
pub struct OwnedMutexGuard<T: ?Sized> { /* 私有字段 */ }
展开描述

对持有 Mutex 的 owned 句柄。

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

只要你拥有此 guard,你就可以独占访问底层的 T。该 guard 在内部保持指向原始 Mutex 的引用计数指针,因此即使锁消失了,guard 仍然有效。

每当守卫被 drop 时,锁会自动释放,此时 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,则返回原始守卫。

此操作不会失败,因为传入的 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,

自动 trait 实现§

§

impl<T> Freeze for OwnedMutexGuard<T>
where T: ?Sized,

§

impl<T> !RefUnwindSafe for OwnedMutexGuard<T>

§

impl<T> Send for OwnedMutexGuard<T>
where T: Send + ?Sized,

§

impl<T> Unpin for OwnedMutexGuard<T>
where T: ?Sized,

§

impl<T> UnsafeUnpin for OwnedMutexGuard<T>
where T: ?Sized,

§

impl<T> !UnwindSafe for OwnedMutexGuard<T>

blanket 实现§

源代码§

impl<T> Any for T
where T: 'static + ?Sized,

源代码§

fn type_id(&self) -> TypeId

Gets the TypeId of self. 更多信息
源代码§

impl<T> Borrow<T> for T
where T: ?Sized,

源代码§

fn borrow(&self) -> &T

Immutably borrows from an owned value. 更多信息
源代码§

impl<T> BorrowMut<T> for T
where T: ?Sized,

源代码§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. 更多信息
源代码§

impl<T> From<T> for T

源代码§

fn from(t: T) -> T

原样返回参数。

源代码§

impl<T, U> Into<U> for T
where U: From<T>,

源代码§

fn into(self) -> U

调用 U::from(self)

也就是说,此转换是 From<T> for U 实现选择执行的操作。

源代码§

impl<P, T> Receiver for P
where P: Deref<Target = T> + ?Sized, T: ?Sized,

源代码§

type Target = T

🔬This is a nightly-only experimental API. (arbitrary_self_types)
The target type on which the method may be called.
源代码§

impl<T> ToString for T
where T: Display + ?Sized,

源代码§

fn to_string(&self) -> String

Converts the given value to a String. 更多信息
源代码§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

源代码§

type Error = Infallible

转换出错时返回的类型。
源代码§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

执行转换。
源代码§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

源代码§

type Error = <U as TryFrom<T>>::Error

转换出错时返回的类型。
源代码§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

执行转换。