Struct ModelOperationLock 

pub struct ModelOperationLock {
    locks: Arc<RwLock<HashMap<i64, OperationType>>>,
}

Concurrency control for model operations.

Ensures only one operation of each type can run on a model at a time.

Fields

locks: Arc<RwLock<HashMap<i64, OperationType>>>

Implementations

impl ModelOperationLock

pub fn new() -> Self

Create a new operation lock manager.

pub async fn try_acquire( &self, model_id: i64, operation: OperationType, ) -> Result<OperationGuard, String>

Try to acquire a lock for the specified operation.

Returns Ok(guard) if the lock was acquired, or Err if another operation is already in progress for this model.

Trait Implementations

impl Default for ModelOperationLock

fn default() -> Self

Returns the “default value” for a type.