Struct ConcurrencyLock 

pub struct ConcurrencyLock { /* private fields */ }

Concurrency lock manager

Provides file-based locking for concurrency groups. Locks are automatically released when the guard is dropped.

Stale Lock Detection

Locks are considered stale if their age (based on the acquired_at timestamp stored in the lock file) exceeds the configured stale_threshold. This approach has a limitation: if the lock holder process crashes without releasing the lock, the staleness is determined by the original acquisition time, not by process liveness. This means a lock may be held longer than expected if the holder process hangs but doesn’t crash.

For truly distributed scenarios, consider integrating with a proper distributed lock service (e.g., etcd, Redis, or cloud-native locking APIs).

Implementations

impl ConcurrencyLock

pub fn new() -> Self

Create a new lock manager with default configuration

pub fn with_config(config: LockConfig) -> Self

Create a lock manager with custom configuration

pub fn with_lock_dir(self, dir: impl Into<PathBuf>) -> Self

Set the lock directory

pub fn with_timeout(self, timeout: Duration) -> Self

Set the lock acquisition timeout

pub async fn acquire( &self, group: &str, task_id: &str, ) -> Result<LockGuard, LockError>

Acquire a lock for the given concurrency group

Blocks until the lock is acquired or timeout is reached.

Arguments

• group - Concurrency group name
• task_id - Task ID acquiring the lock (for diagnostics)

Errors

Returns error if lock cannot be acquired within timeout

pub fn try_acquire_sync( &self, group: &str, task_id: &str, ) -> Result<LockGuard, LockError>

Try to acquire lock without blocking

Errors

Returns LockError if lock cannot be acquired or lock directory cannot be created.

pub fn is_locked(&self, group: &str) -> bool

Check if a lock is currently held

pub fn lock_info(&self, group: &str) -> Option<LockMetadata>

Get information about current lock holder

Trait Implementations

impl Debug for ConcurrencyLock

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

Formats the value using the given formatter.

impl Default for ConcurrencyLock

fn default() -> Self

Returns the “default value” for a type.