Struct crossbeam::sync::ShardedLock

pub struct ShardedLock<T> { /* private fields */ }

A scalable reader-writer lock.

This type of lock allows a number of readers or at most one writer at any point in time. The write portion of this lock typically allows modification of the underlying data (exclusive access) and the read portion of this lock typically allows for read-only access (shared access).

This reader-writer lock differs from typical implementations in that it internally creates a list of reader-writer locks called ‘shards’. Shards are aligned and padded to the cache line size.

Read operations lock only one shard specific to the current thread, while write operations lock every shard in succession. This strategy makes concurrent read operations faster due to less contention, but write operations are slower due to increased amount of locking.

Implementations

impl<T> ShardedLock<T>

pub fn new(value: T) -> ShardedLock<T>

Creates a new ShardedLock initialized with value.

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

Locks 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 drop the read access of this lock when dropped.

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

Locks 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 lock when dropped.

Trait Implementations

impl<T: Debug> Debug for ShardedLock<T>

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

Formats the value using the given formatter.

impl<T: Send> Send for ShardedLock<T>

impl<T: Send + Sync> Sync for ShardedLock<T>