Struct MemoryTaskLock 

pub struct MemoryTaskLock { /* private fields */ }

In-memory task lock for single-process testing

Examples

use reinhardt_tasks::{MemoryTaskLock, TaskLock, TaskId};
use std::time::Duration;

let lock = MemoryTaskLock::new();
let task_id = TaskId::new();

// Acquire lock
let token = lock.acquire(task_id, Duration::from_secs(60)).await?;
assert!(token.is_some());

// Check if locked
let is_locked = lock.is_locked(task_id).await?;
assert!(is_locked);

// Release lock
let released = lock.release(task_id, &token.unwrap()).await?;
assert!(released);

Implementations

impl MemoryTaskLock

pub fn new() -> Self

Create a new in-memory task lock

Examples

use reinhardt_tasks::MemoryTaskLock;

let lock = MemoryTaskLock::new();

Trait Implementations

impl Default for MemoryTaskLock

fn default() -> Self

Returns the “default value” for a type.

impl TaskLock for MemoryTaskLock

fn extend<'life0, 'life1, 'async_trait>( &'life0 self, task_id: TaskId, token: &'life1 LockToken, ttl: Duration, ) -> Pin<Box<dyn Future<Output = TaskResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Atomically extend the TTL of an existing lock.

Unlike the default trait implementation which releases then re-acquires, this holds the write lock throughout the operation to prevent another worker from stealing the lock in between.

fn acquire<'life0, 'async_trait>( &'life0 self, task_id: TaskId, ttl: Duration, ) -> Pin<Box<dyn Future<Output = TaskResult<Option<LockToken>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Acquire a lock for a task

fn release<'life0, 'life1, 'async_trait>( &'life0 self, task_id: TaskId, token: &'life1 LockToken, ) -> Pin<Box<dyn Future<Output = TaskResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Release a lock for a task

fn is_locked<'life0, 'async_trait>( &'life0 self, task_id: TaskId, ) -> Pin<Box<dyn Future<Output = TaskResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if a task is locked