scaibu_mutex_lock library

Classes

AtomicLock

A high-performance, optimized atomic lock implementation for Dart.

CircuitBreakerMutex

A CircuitBreaker implementation to prevent cascading failures in distributed systems by limiting the number of failed operations.

ComposedLock

A class that manages multiple mutex locks in a structured manner. It provides mechanisms for acquiring locks sequentially or atomically and ensures proper release of acquired locks.

IMetricsCollector

Interface for mutex metrics collection An interface for collecting various lock-related metrics.

IMutex

Primary interface for all mutex (mutual exclusion) operations.

IMutexPool

Interface for managing a pool of mutexes.

MetricsCollector

Implementation of mutex metrics collection

MutexPool

Efficient mutex pooling with automatic cleanup.

MutexService

Main service facade that coordinates mutex operations.

MutexTransaction

A class that manages a transaction involving multiple mutexes, ensuring proper acquisition and release to prevent deadlocks.

PoolEntry

Represents an entry in the mutex pool for tracking access times.

PriorityMutex

A mutex (mutual exclusion) mechanism that allows priority-based locking.

ReadWriteLock

A Read-Write Lock implementation that allows multiple readers but only one writer.

ResourcePool<T>

A generic resource pool that manages a set of reusable resources. This ensures controlled access to a limited number of resources using a mutual exclusion (mutex) mechanism.

SimpleMutex

UltraMutex

High-performance mutex implementation with contention handling.

Extensions

HighScalableStreamUtils on Stream<T>

Extension providing high-performance stream collection