Type Alias spin::RwLock

pub type RwLock<T> = RwLock<T>;

A lock that provides data access to either one writer or many readers. See rwlock::RwLock for documentation.

A note for advanced users: this alias exists to avoid subtle type inference errors due to the default relax strategy type parameter. If you need a non-default relax strategy, use the fully-qualified path.

Aliased Type

struct RwLock<T> { /* private fields */ }

Implementations

impl<T, R> RwLock<T, R>

pub const fn new(data: T) -> Self

Creates a new spinlock wrapping the supplied data.

May be used statically:

use spin;

static RW_LOCK: spin::RwLock<()> = spin::RwLock::new(());

fn demo() {
    let lock = RW_LOCK.read();
    // do something with lock
    drop(lock);
}

pub fn into_inner(self) -> T

Consumes this RwLock, returning the underlying data.

pub fn as_mut_ptr(&self) -> *mut T

Returns a mutable pointer to the underying data.

This is mostly meant to be used for applications which require manual unlocking, but where storing both the lock and the pointer to the inner data gets inefficient.

While this is safe, writing to the data is undefined behavior unless the current thread has acquired a write lock, and reading requires either a read or write lock.

Example

let lock = spin::RwLock::new(42);

unsafe {
    core::mem::forget(lock.write());

    assert_eq!(lock.as_mut_ptr().read(), 42);
    lock.as_mut_ptr().write(58);

    lock.force_write_unlock();
}

assert_eq!(*lock.read(), 58);

impl<T: ?Sized, R: RelaxStrategy> RwLock<T, R>

pub fn read(&self) -> RwLockReadGuard<'_, T>

Locks this rwlock with shared read access, blocking the current thread until it can be acquired.

The calling thread will be blocked until there are no more writers which hold the lock. There may be other readers currently inside the lock when this method returns. This method does not provide any guarantees with respect to the ordering of whether contentious readers or writers will acquire the lock first.

Returns an RAII guard which will release this thread’s shared access once it is dropped.

let mylock = spin::RwLock::new(0);
{
    let mut data = mylock.read();
    // The lock is now locked and the data can be read
    println!("{}", *data);
    // The lock is dropped
}

pub fn write(&self) -> RwLockWriteGuard<'_, T, R>

Lock this rwlock with exclusive write access, blocking the current thread until it can be acquired.

This function will not return while other writers or other readers currently have access to the lock.

Returns an RAII guard which will drop the write access of this rwlock when dropped.

let mylock = spin::RwLock::new(0);
{
    let mut data = mylock.write();
    // The lock is now locked and the data can be written
    *data += 1;
    // The lock is dropped
}

pub fn upgradeable_read(&self) -> RwLockUpgradableGuard<'_, T, R>

Obtain a readable lock guard that can later be upgraded to a writable lock guard. Upgrades can be done through the RwLockUpgradableGuard::upgrade method.

impl<T: ?Sized, R> RwLock<T, R>

pub fn try_read(&self) -> Option<RwLockReadGuard<'_, T>>

Attempt to acquire this lock with shared read access.

This function will never block and will return immediately if read would otherwise succeed. Returns Some of an RAII guard which will release the shared access of this thread when dropped, or None if the access could not be granted. This method does not provide any guarantees with respect to the ordering of whether contentious readers or writers will acquire the lock first.

let mylock = spin::RwLock::new(0);
{
    match mylock.try_read() {
        Some(data) => {
            // The lock is now locked and the data can be read
            println!("{}", *data);
            // The lock is dropped
        },
        None => (), // no cigar
    };
}

pub fn reader_count(&self) -> usize

Return the number of readers that currently hold the lock (including upgradable readers).

Safety

This function provides no synchronization guarantees and so its result should be considered ‘out of date’ the instant it is called. Do not use it for synchronization purposes. However, it may be useful as a heuristic.

pub fn writer_count(&self) -> usize

Return the number of writers that currently hold the lock.

Because RwLock guarantees exclusive mutable access, this function may only return either 0 or 1.

Safety

This function provides no synchronization guarantees and so its result should be considered ‘out of date’ the instant it is called. Do not use it for synchronization purposes. However, it may be useful as a heuristic.

pub unsafe fn force_read_decrement(&self)

Force decrement the reader count.

Safety

This is extremely unsafe if there are outstanding RwLockReadGuards live, or if called more times than read has been called, but can be useful in FFI contexts where the caller doesn’t know how to deal with RAII. The underlying atomic operation uses Ordering::Release.

pub unsafe fn force_write_unlock(&self)

Force unlock exclusive write access.

Safety

This is extremely unsafe if there are outstanding RwLockWriteGuards live, or if called when there are current readers, but can be useful in FFI contexts where the caller doesn’t know how to deal with RAII. The underlying atomic operation uses Ordering::Release.

pub fn try_write(&self) -> Option<RwLockWriteGuard<'_, T, R>>

Attempt to lock this rwlock with exclusive write access.

This function does not ever block, and it will return None if a call to write would otherwise block. If successful, an RAII guard is returned.

let mylock = spin::RwLock::new(0);
{
    match mylock.try_write() {
        Some(mut data) => {
            // The lock is now locked and the data can be written
            *data += 1;
            // The lock is implicitly dropped
        },
        None => (), // no cigar
    };
}

pub fn try_upgradeable_read(&self) -> Option<RwLockUpgradableGuard<'_, T, R>>

Tries to obtain an upgradeable lock guard.

pub fn get_mut(&mut self) -> &mut T

Returns a mutable reference to the underlying data.

Since this call borrows the RwLock mutably, no actual locking needs to take place – the mutable borrow statically guarantees no locks exist.

Examples

let mut lock = spin::RwLock::new(0);
*lock.get_mut() = 10;
assert_eq!(*lock.read(), 10);

Trait Implementations

impl<T: ?Sized + Debug, R> Debug for RwLock<T, R>

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

Formats the value using the given formatter.

impl<T: ?Sized + Default, R> Default for RwLock<T, R>

fn default() -> Self

Returns the “default value” for a type.

impl<T, R> From<T> for RwLock<T, R>

fn from(data: T) -> Self

Converts to this type from the input type.

impl<R: RelaxStrategy> RawRwLock for RwLock<(), R>

type GuardMarker = GuardSend

Marker type which determines whether a lock guard should be Send. Use one of the GuardSend or GuardNoSend helper types here.

const INIT: Self = _

Initial value for an unlocked RwLock.

fn lock_exclusive(&self)

Acquires an exclusive lock, blocking the current thread until it is able to do so.

fn try_lock_exclusive(&self) -> bool

Attempts to acquire an exclusive lock without blocking.

unsafe fn unlock_exclusive(&self)

Releases an exclusive lock.

fn lock_shared(&self)

Acquires a shared lock, blocking the current thread until it is able to do so.

fn try_lock_shared(&self) -> bool

Attempts to acquire a shared lock without blocking.

unsafe fn unlock_shared(&self)

Releases a shared lock.

fn is_locked(&self) -> bool

Checks if this RwLock is currently locked in any way.

fn is_locked_exclusive(&self) -> bool

Check if this RwLock is currently exclusively locked.

impl<R: RelaxStrategy> RawRwLockDowngrade for RwLock<(), R>

unsafe fn downgrade(&self)

Atomically downgrades an exclusive lock into a shared lock without allowing any thread to take an exclusive lock in the meantime.

impl<R: RelaxStrategy> RawRwLockUpgrade for RwLock<(), R>

fn lock_upgradable(&self)

Acquires an upgradable lock, blocking the current thread until it is able to do so.

fn try_lock_upgradable(&self) -> bool

Attempts to acquire an upgradable lock without blocking.

unsafe fn unlock_upgradable(&self)

Releases an upgradable lock.

unsafe fn upgrade(&self)

Upgrades an upgradable lock to an exclusive lock.

unsafe fn try_upgrade(&self) -> bool

Attempts to upgrade an upgradable lock to an exclusive lock without blocking.

impl<T: ?Sized + Send, R> Send for RwLock<T, R>

impl<T: ?Sized + Send + Sync, R> Sync for RwLock<T, R>