Структура RwLockWriteGuard

Создаёт новый RwLockMappedWriteGuard для компонента заблокированных данных.

Эта операция не может завершиться ошибкой, поскольку переданный RwLockWriteGuard уже заблокировал данные.

Это ассоциированная функция, которую необходимо вызывать как RwLockWriteGuard::map(..). Метод мешал бы одноимённым методам содержимого заблокированных данных.

Это асинхронная версия RwLockWriteGuard::map из crate parking_lot.

Примеры

use tokio::sync::{RwLock, RwLockWriteGuard};

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

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

{
    let mut mapped = RwLockWriteGuard::map(lock.write().await, |f| &mut f.0);
    *mapped = 2;
}

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

Создаёт новый RwLockReadGuard для компонента заблокированных данных.

Эта операция не может завершиться ошибкой, поскольку переданный RwLockWriteGuard уже заблокировал данные.

Это ассоциированная функция, которую необходимо вызывать как RwLockWriteGuard::downgrade_map(..). Метод мешал бы одноимённым методам содержимого заблокированных данных.

Это эквивалент комбинации асинхронных RwLockWriteGuard::map и RwLockWriteGuard::downgrade из crate parking_lot.

Внутри f вы сохраняете эксклюзивный доступ к данным, несмотря на то что вам предоставлен только &T. Передача &mut T привела бы к нарушению безопасности, поскольку вы могли бы использовать внутреннюю изменяемость.

Примеры

use tokio::sync::{RwLock, RwLockWriteGuard};

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

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

let mapped = RwLockWriteGuard::downgrade_map(lock.write().await, |f| &f.0);
let foo = lock.read().await;
assert_eq!(foo.0, *mapped);

Пытается создать новый RwLockMappedWriteGuard для компонента заблокированных данных. Если замыкание возвращает None, возвращается исходный guard.

Эта операция не может завершиться ошибкой, поскольку переданный RwLockWriteGuard уже заблокировал данные.

Это ассоциированная функция, которую необходимо вызывать как RwLockWriteGuard::try_map(...). Метод мешал бы одноимённым методам содержимого заблокированных данных.

Это асинхронная версия RwLockWriteGuard::try_map из crate parking_lot.

Примеры

use tokio::sync::{RwLock, RwLockWriteGuard};

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

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

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

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

Пытается создать новый RwLockReadGuard для компонента заблокированных данных. Если замыкание возвращает None, возвращается исходный guard.

Эта операция не может завершиться неудачей, поскольку переданный RwLockWriteGuard уже заблокировал данные.

Это ассоциированная функция, которую необходимо вызывать как RwLockWriteGuard::try_downgrade_map(...). Метод помешал бы использовать методы с таким же именем у содержимого заблокированных данных.

Это эквивалентно сочетанию асинхронных RwLockWriteGuard::try_map и RwLockWriteGuard::downgrade из крейта parking_lot.

Внутри f вы сохраняете эксклюзивный доступ к данным, несмотря на то что получили только &T. Передача &mut T привела бы к нарушению безопасности, поскольку можно было бы использовать внутреннюю изменяемость.

Если эта функция возвращает Err(...), блокировка никогда не снимается и не понижается.

Примеры

use tokio::sync::{RwLock, RwLockWriteGuard};

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

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

let guard = RwLockWriteGuard::try_downgrade_map(lock.write().await, |f| Some(&f.0)).expect("should not fail");
let foo = lock.read().await;
assert_eq!(foo.0, *guard);

Преобразует этот RwLockWriteGuard в RwLockMappedWriteGuard. Этот метод можно использовать, чтобы сохранить немаппированный guard в поле структуры, для которого требуется маппированный guard.

Это эквивалентно вызову RwLockWriteGuard::map(guard, |me| me).

Атомарно понижает блокировку записи до блокировки чтения, не позволяя другим потокам получить эксклюзивный доступ к блокировке в это время.

Примечание: Это не обязательно позволит другим читателям получить блокировку, поскольку RwLock справедлива, и следующим в очереди может быть писатель.

Возвращает guard RAII, который при уничтожении освобождает доступ на чтение к RwLock.

Примеры

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

let n = lock.write().await;

let cloned_lock = lock.clone();
let handle = tokio::spawn(async move {
    *cloned_lock.write().await = 2;
});

let n = n.downgrade();
assert_eq!(*n, 1, "downgrade is atomic");

drop(n);
handle.await.unwrap();
assert_eq!(*lock.read().await, 2, "second writer obtained write lock");

Возвращает аргумент без изменений.

Вызывает U::from(self).

То есть это преобразование выполняет то, что выберет реализация From<T> for U.