RwLockWriteGuard

Struct RwLockWriteGuard 

Source
pub struct RwLockWriteGuard<'rwlock, T>
where T: 'rwlock + ?Sized,
{ lock: &'rwlock RwLock<T>, poison: Guard, }
๐Ÿ”ฌThis is a nightly-only experimental API. (sync_poison_mod)
Expand description

RAII structure used to release the exclusive write access of a lock when dropped.

This structure is created by the write and try_write methods on RwLock.

Fieldsยง

ยงlock: &'rwlock RwLock<T>
๐Ÿ”ฌThis is a nightly-only experimental API. (sync_poison_mod)
ยงpoison: Guard
๐Ÿ”ฌThis is a nightly-only experimental API. (sync_poison_mod)

Implementationsยง

Sourceยง

impl<'rwlock, T> RwLockWriteGuard<'rwlock, T>
where T: ?Sized,

1.92.0 ยท Source

pub fn downgrade(s: RwLockWriteGuard<'rwlock, T>) -> RwLockReadGuard<'rwlock, T>

Downgrades a write-locked RwLockWriteGuard into a read-locked RwLockReadGuard.

Since we have the RwLockWriteGuard, the RwLock must already be locked for writing, so this method cannot fail.

After downgrading, other readers will be allowed to read the protected data.

ยงExamples

downgrade takes ownership of the RwLockWriteGuard and returns a RwLockReadGuard.

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

let rw = RwLock::new(0);

let mut write_guard = rw.write().unwrap();
*write_guard = 42;

let read_guard = RwLockWriteGuard::downgrade(write_guard);
assert_eq!(42, *read_guard);

downgrade will atomically change the state of the RwLock from exclusive mode into shared mode. This means that it is impossible for another writing thread to get in between a thread calling downgrade and any reads it performs after downgrading.

use std::sync::{Arc, RwLock, RwLockWriteGuard};

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

// Put the lock in write mode.
let mut main_write_guard = rw.write().unwrap();

let rw_clone = rw.clone();
let evil_handle = std::thread::spawn(move || {
    // This will not return until the main thread drops the `main_read_guard`.
    let mut evil_guard = rw_clone.write().unwrap();

    assert_eq!(*evil_guard, 2);
    *evil_guard = 3;
});

*main_write_guard = 2;

// Atomically downgrade the write guard into a read guard.
let main_read_guard = RwLockWriteGuard::downgrade(main_write_guard);

// Since `downgrade` is atomic, the writer thread cannot have changed the protected data.
assert_eq!(*main_read_guard, 2, "`downgrade` was not atomic");
Source

pub fn map<U, F>( orig: RwLockWriteGuard<'rwlock, T>, f: F, ) -> MappedRwLockWriteGuard<'rwlock, U>
where F: FnOnce(&mut T) -> &mut U, U: ?Sized,

๐Ÿ”ฌThis is a nightly-only experimental API. (mapped_lock_guards)

Makes a MappedRwLockWriteGuard for a component of the borrowed data, e.g. an enum variant.

The RwLock is already locked for writing, so this cannot fail.

This is an associated function that needs to be used as RwLockWriteGuard::map(...). A method would interfere with methods of the same name on the contents of the RwLockWriteGuard used through Deref.

ยงPanics

If the closure panics, the guard will be dropped (unlocked) and the RwLock will be poisoned.

Source

pub fn filter_map<U, F>( orig: RwLockWriteGuard<'rwlock, T>, f: F, ) -> Result<MappedRwLockWriteGuard<'rwlock, U>, RwLockWriteGuard<'rwlock, T>>
where F: FnOnce(&mut T) -> Option<&mut U>, U: ?Sized,

๐Ÿ”ฌThis is a nightly-only experimental API. (mapped_lock_guards)

Makes a MappedRwLockWriteGuard for a component of the borrowed data. The original guard is returned as an Err(...) if the closure returns None.

The RwLock is already locked for writing, so this cannot fail.

This is an associated function that needs to be used as RwLockWriteGuard::filter_map(...). A method would interfere with methods of the same name on the contents of the RwLockWriteGuard used through Deref.

ยงPanics

If the closure panics, the guard will be dropped (unlocked) and the RwLock will be poisoned.

Trait Implementationsยง

1.16.0 ยท Sourceยง

impl<T> Debug for RwLockWriteGuard<'_, T>
where T: Debug + ?Sized,

Sourceยง

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter. Read more
1.0.0 ยท Sourceยง

impl<T> Deref for RwLockWriteGuard<'_, T>
where T: ?Sized,

Sourceยง

type Target = T

The resulting type after dereferencing.
Sourceยง

fn deref(&self) -> &T

Dereferences the value.
1.0.0 ยท Sourceยง

impl<T> DerefMut for RwLockWriteGuard<'_, T>
where T: ?Sized,

Sourceยง

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

Mutably dereferences the value.
1.20.0 ยท Sourceยง

impl<T> Display for RwLockWriteGuard<'_, T>
where T: Display + ?Sized,

Sourceยง

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter. Read more
1.0.0 ยท Sourceยง

impl<T> Drop for RwLockWriteGuard<'_, T>
where T: ?Sized,

Sourceยง

fn drop(&mut self)

Executes the destructor for this type. Read more
1.0.0 ยท Sourceยง

impl<T> !Send for RwLockWriteGuard<'_, T>
where T: ?Sized,

ยง

impl<'a, T> StableDeref for RwLockWriteGuard<'a, T>
where T: ?Sized,

Available on crate feature std only.
1.23.0 ยท Sourceยง

impl<T> Sync for RwLockWriteGuard<'_, T>
where T: Sync + ?Sized,

Auto Trait Implementationsยง

ยง

impl<'rwlock, T> Freeze for RwLockWriteGuard<'rwlock, T>
where T: ?Sized,

ยง

impl<'rwlock, T> RefUnwindSafe for RwLockWriteGuard<'rwlock, T>
where T: ?Sized,

ยง

impl<'rwlock, T> Unpin for RwLockWriteGuard<'rwlock, T>
where T: ?Sized,

ยง

impl<'rwlock, T> UnwindSafe for RwLockWriteGuard<'rwlock, T>
where T: ?Sized,

Blanket Implementationsยง

Sourceยง

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

Sourceยง

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
ยง

impl<T> ArchivePointee for T

ยง

type ArchivedMetadata = ()

The archived version of the pointer metadata for this type.
ยง

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

Converts some archived metadata to the pointer metadata for itself.
Sourceยง

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

Sourceยง

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Sourceยง

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

Sourceยง

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

Mutably borrows from an owned value. Read more
Sourceยง

impl<T> From<T> for T

Sourceยง

fn from(t: T) -> T

Returns the argument unchanged.

ยง

impl<T> Instrument for T

ยง

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
ยง

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Sourceยง

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

Sourceยง

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Sourceยง

impl<T> IntoEither for T

Sourceยง

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Sourceยง

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
ยง

impl<T> LayoutRaw for T

ยง

fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>

Returns the layout of the type.
ยง

impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
where T: SharedNiching<N1, N2>, N1: Niching<T>, N2: Niching<T>,

ยง

unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool

Returns whether the given value has been niched. Read more
ยง

fn resolve_niched(out: Place<NichedOption<T, N1>>)

Writes data to out indicating that a T is niched.
ยง

impl<T> Pointable for T

ยง

const ALIGN: usize

The alignment of pointer.
ยง

type Init = T

The type for initializers.
ยง

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
ยง

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
ยง

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
ยง

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
ยง

impl<T> Pointee for T

ยง

type Metadata = ()

The metadata type for pointers and references to this type.
Sourceยง

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

Sourceยง

type Target = T

๐Ÿ”ฌThis is a nightly-only experimental API. (arbitrary_self_types)
The target type on which the method may be called.
ยง

impl<R> Rng for R
where R: TryRng<Error = Infallible> + ?Sized,

ยง

fn next_u32(&mut self) -> u32

Return the next random u32.
ยง

fn next_u64(&mut self) -> u64

Return the next random u64.
ยง

fn fill_bytes(&mut self, dst: &mut [u8])

Fill dest with random data. Read more
ยง

impl<R> RngExt for R
where R: Rng + ?Sized,

ยง

fn random<T>(&mut self) -> T
where StandardUniform: Distribution<T>,

Return a random value via the StandardUniform distribution. Read more
ยง

fn random_iter<T>(self) -> Iter<StandardUniform, Self, T>
where Self: Sized, StandardUniform: Distribution<T>,

Return an iterator over random variates Read more
ยง

fn random_range<T, R>(&mut self, range: R) -> T
where T: SampleUniform, R: SampleRange<T>,

Generate a random value in the given range. Read more
ยง

fn random_bool(&mut self, p: f64) -> bool

Return a bool with a probability p of being true. Read more
ยง

fn random_ratio(&mut self, numerator: u32, denominator: u32) -> bool

Return a bool with a probability of numerator/denominator of being true. Read more
ยง

fn sample<T, D>(&mut self, distr: D) -> T
where D: Distribution<T>,

Sample a new value, using the given distribution. Read more
ยง

fn sample_iter<T, D>(self, distr: D) -> Iter<D, Self, T>
where D: Distribution<T>, Self: Sized,

Create an iterator that generates values using the given distribution. Read more
ยง

fn fill<T>(&mut self, dest: &mut [T])
where T: Fill,

Fill any type implementing [Fill] with random data Read more
Sourceยง

impl<T> Same for T

Sourceยง

type Output = T

Should always be Self
Sourceยง

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

Sourceยง

fn to_string(&self) -> String

Converts the given value to a String. Read more
Sourceยง

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

Sourceยง

type Error = Infallible

The type returned in the event of a conversion error.
Sourceยง

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

Performs the conversion.
Sourceยง

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

Sourceยง

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

The type returned in the event of a conversion error.
Sourceยง

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

Performs the conversion.
ยง

impl<R> TryRng for R
where R: DerefMut, <R as Deref>::Target: TryRng,

ยง

type Error = <<R as Deref>::Target as TryRng>::Error

The type returned in the event of a RNG error. Read more
ยง

fn try_next_u32(&mut self) -> Result<u32, <R as TryRng>::Error>

Return the next random u32.
ยง

fn try_next_u64(&mut self) -> Result<u64, <R as TryRng>::Error>

Return the next random u64.
ยง

fn try_fill_bytes(&mut self, dst: &mut [u8]) -> Result<(), <R as TryRng>::Error>

Fill dst entirely with random data.
ยง

impl<R> TryRngCore for R
where R: TryRng,

ยง

type Error = <R as TryRng>::Error

๐Ÿ‘ŽDeprecated since 0.10.0: use TryRng instead
Error type.
ยง

impl<T> WithSubscriber for T

ยง

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
ยง

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
ยง

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

ยง

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

ยง

impl<R> CryptoRng for R
where R: TryCryptoRng<Error = Infallible> + ?Sized,

ยง

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

ยง

impl<R> RngCore for R
where R: Rng,

ยง

impl<R> TryCryptoRng for R
where R: DerefMut, <R as Deref>::Target: TryCryptoRng,