pub struct RwLockUpgradableReadGuard<'a, R: RawRwLockUpgrade, T: ?Sized> { /* private fields */ }Expand description
An RAII guard which releases upgradable read access when dropped.
This structure is created by the
upgradable_read and
try_upgradable_read methods on RwLock.
Implementations§
Source§impl<'a, R: RawRwLockUpgrade + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
impl<'a, R: RawRwLockUpgrade + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
Sourcepub fn rwlock(s: &Self) -> &'a RwLock<R, T>
pub fn rwlock(s: &Self) -> &'a RwLock<R, T>
Returns a reference to the original reader-writer lock object.
Sourcepub fn unlocked<F, U>(s: &mut Self, f: F) -> Uwhere
F: FnOnce() -> U,
pub fn unlocked<F, U>(s: &mut Self, f: F) -> Uwhere
F: FnOnce() -> U,
Temporarily unlocks the RwLock to execute the given function.
The mutable reference ensures that no references derived from this guard are live while the lock is temporarily released.
§Aborts
Aborts if re-locking the RwLock panics.
Sourcepub fn upgrade(s: Self) -> RwLockWriteGuard<'a, R, T>
pub fn upgrade(s: Self) -> RwLockWriteGuard<'a, R, T>
Atomically upgrades an upgradable read lock into an exclusive write lock, blocking the current thread until it can be acquired.
This cannot complete while any other read guards remain. Calling it while the current thread holds another read guard may therefore deadlock.
Sourcepub fn try_upgrade(s: Self) -> Result<RwLockWriteGuard<'a, R, T>, Self>
pub fn try_upgrade(s: Self) -> Result<RwLockWriteGuard<'a, R, T>, Self>
Tries to atomically upgrade an upgradable read lock into an exclusive write lock.
If the access could not be granted at this time, then the current guard is returned.
Source§impl<'a, R: RawRwLockUpgradeFair + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
impl<'a, R: RawRwLockUpgradeFair + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
Sourcepub fn unlock_fair(s: Self)
pub fn unlock_fair(s: Self)
Unlocks the RwLock using a fair unlock protocol.
A fair unlock gives waiting threads priority over new acquisition attempts. This can prevent starvation, but may reduce throughput by forcing a context switch.
Sourcepub fn unlocked_fair<F, U>(s: &mut Self, f: F) -> Uwhere
F: FnOnce() -> U,
pub fn unlocked_fair<F, U>(s: &mut Self, f: F) -> Uwhere
F: FnOnce() -> U,
Temporarily unlocks the RwLock to execute the given function.
The RwLock is unlocked using a fair unlock protocol.
The mutable reference ensures that no references derived from this guard are live while the lock is temporarily released.
§Aborts
Aborts if re-locking the RwLock panics.
Source§impl<'a, R: RawRwLockUpgradeDowngrade + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
impl<'a, R: RawRwLockUpgradeDowngrade + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
Sourcepub fn downgrade(s: Self) -> RwLockReadGuard<'a, R, T>
pub fn downgrade(s: Self) -> RwLockReadGuard<'a, R, T>
Atomically downgrades an upgradable read lock into a shared read lock without allowing any writers to take exclusive access of the lock in the meantime.
Note that if there are any writers currently waiting to take the lock then other readers may not be able to acquire the lock even if it was downgraded.
Sourcepub fn with_upgraded<Ret, F: FnOnce(&mut T) -> Ret>(&mut self, f: F) -> Ret
pub fn with_upgraded<Ret, F: FnOnce(&mut T) -> Ret>(&mut self, f: F) -> Ret
First, atomically upgrades an upgradable read lock into an exclusive write lock, blocking the current thread until it can be acquired. This cannot complete while any other read guards remain.
Then, calls the provided closure with an exclusive reference to the lock’s data.
Finally, atomically downgrades the lock back to an upgradable read lock. The closure’s return value is returned.
This function only requires a mutable reference to the guard, unlike
upgrade which takes the guard by value.
§Aborts
Aborts if upgrading or downgrading back to an upgradable read lock panics, since releasing and re-acquiring would break continuous lock ownership.
Sourcepub fn try_with_upgraded<Ret, F: FnOnce(&mut T) -> Ret>(
&mut self,
f: F,
) -> Option<Ret>
pub fn try_with_upgraded<Ret, F: FnOnce(&mut T) -> Ret>( &mut self, f: F, ) -> Option<Ret>
First, tries to atomically upgrade an upgradable read lock into an exclusive write lock.
If the access could not be granted at this time, then None is returned.
Otherwise, calls the provided closure with an exclusive reference to the lock’s data,
and finally downgrades the lock back to an upgradable read lock.
The closure’s return value is wrapped in Some and returned.
This function only requires a mutable reference to the guard, unlike
try_upgrade which takes the guard by value.
§Aborts
Aborts if upgrading or downgrading back to an upgradable read lock panics, since releasing and re-acquiring would break continuous lock ownership.
Source§impl<'a, R: RawRwLockUpgradeTimed + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
impl<'a, R: RawRwLockUpgradeTimed + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
Sourcepub fn try_upgrade_for(
s: Self,
timeout: R::Duration,
) -> Result<RwLockWriteGuard<'a, R, T>, Self>
pub fn try_upgrade_for( s: Self, timeout: R::Duration, ) -> Result<RwLockWriteGuard<'a, R, T>, Self>
Tries to atomically upgrade an upgradable read lock into an exclusive write lock, until a timeout is reached.
If the access could not be granted before the timeout expires, then the current guard is returned.
See RawRwLockUpgradeTimed::try_upgrade_for for timeout behavior.
Sourcepub fn try_upgrade_until(
s: Self,
timeout: R::Instant,
) -> Result<RwLockWriteGuard<'a, R, T>, Self>
pub fn try_upgrade_until( s: Self, timeout: R::Instant, ) -> Result<RwLockWriteGuard<'a, R, T>, Self>
Tries to atomically upgrade an upgradable read lock into an exclusive write lock, until a timeout is reached.
If the access could not be granted before the timeout expires, then the current guard is returned.
See RawRwLockUpgradeTimed::try_upgrade_until for timeout behavior.
Source§impl<'a, R: RawRwLockUpgradeTimed + RawRwLockUpgradeDowngrade + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
impl<'a, R: RawRwLockUpgradeTimed + RawRwLockUpgradeDowngrade + 'a, T: ?Sized + 'a> RwLockUpgradableReadGuard<'a, R, T>
Sourcepub fn try_with_upgraded_for<Ret, F: FnOnce(&mut T) -> Ret>(
&mut self,
timeout: R::Duration,
f: F,
) -> Option<Ret>
pub fn try_with_upgraded_for<Ret, F: FnOnce(&mut T) -> Ret>( &mut self, timeout: R::Duration, f: F, ) -> Option<Ret>
Tries to atomically upgrade an upgradable read lock into an exclusive write lock, until a timeout is reached.
If the access could not be granted before the timeout expires, then
None is returned.
See RawRwLockUpgradeTimed::try_upgrade_for for timeout behavior.
Otherwise, calls the provided closure with an exclusive reference to the lock’s data,
and finally downgrades the lock back to an upgradable read lock.
The closure’s return value is wrapped in Some and returned.
This function only requires a mutable reference to the guard, unlike
try_upgrade_for which takes the guard by value.
§Aborts
Aborts if upgrading or downgrading back to an upgradable read lock panics, since releasing and re-acquiring would break continuous lock ownership.
Sourcepub fn try_with_upgraded_until<Ret, F: FnOnce(&mut T) -> Ret>(
&mut self,
timeout: R::Instant,
f: F,
) -> Option<Ret>
pub fn try_with_upgraded_until<Ret, F: FnOnce(&mut T) -> Ret>( &mut self, timeout: R::Instant, f: F, ) -> Option<Ret>
Tries to atomically upgrade an upgradable read lock into an exclusive write lock, until a timeout is reached.
If the access could not be granted before the timeout expires, then
None is returned.
See RawRwLockUpgradeTimed::try_upgrade_until for timeout behavior.
Otherwise, calls the provided closure with an exclusive reference to the lock’s data,
and finally downgrades the lock back to an upgradable read lock.
The closure’s return value is wrapped in Some and returned.
This function only requires a mutable reference to the guard, unlike
try_upgrade_until which takes the guard by value.
§Aborts
Aborts if upgrading or downgrading back to an upgradable read lock panics, since releasing and re-acquiring would break continuous lock ownership.