Struct LockManager

pub struct LockManager<K: Eq + Hash + Clone> { /* private fields */ }

A thread-safe lock manager that provides key-based locking capabilities.

The LockManager allows concurrent access control based on keys of type K. It supports both single-key and batch locking operations.

Type parameter:

• K: The key type that must implement Eq + Hash + Clone traits

Implementations

impl<K: Eq + Hash + Clone> LockManager<K>

pub fn new() -> Self

Creates a new LockManager instance with default capacity.

pub fn with_capacity(capacity: usize) -> Self

Creates a new LockManager with the specified capacity.

Arguments

• capacity - The initial capacity for the internal map

pub fn with_capacity_and_shard_amount( capacity: usize, shard_amount: usize, ) -> Self

Creates a new LockManager with specified capacity and shard amount.

Arguments

• capacity - The initial capacity for the internal map
• shard_amount - The number of shards to use for internal concurrency

pub fn lock<'a, 'b>(&'a self, key: &'b K) -> LockGuard<'a, 'b, K>

Acquires a lock for a single key.

This method will block until the lock can be acquired.

Arguments

• key - The key to lock

Returns

Returns a LockGuard that will automatically release the lock when dropped

pub fn batch_lock<'a, 'b>( &'a self, keys: &'b BTreeSet<K>, ) -> BatchLockGuard<'a, 'b, K>

Acquires locks for multiple keys atomically.

This method will block until all locks can be acquired. The locks are acquired in a consistent order to prevent deadlocks.

Arguments

• keys - A BTreeSet containing the keys to lock

Returns

Returns a BatchLockGuard that will automatically release all locks when dropped

Trait Implementations

impl<K: Eq + Hash + Clone> Default for LockManager<K>

fn default() -> Self

Returns the “default value” for a type.