Struct ConcurrentState 

pub struct ConcurrentState { /* private fields */ }

Thread-safe wrapper for workflow state during parallel execution.

Uses Arc<RwLock<T>> to allow multiple concurrent reads with exclusive writes. This is optimal for workflow execution where:

• Multiple tasks may read state concurrently
• Only the executor writes state updates

Example

let state = ConcurrentState::new(WorkflowState::new("workflow-1"));

// Concurrent reads (tasks checking state)
{
    let reader = state.read().unwrap();
    assert_eq!(reader.status, WorkflowStatus::Running);
}

// Exclusive write (executor updating state)
{
    let mut writer = state.write().unwrap();
    writer.status = WorkflowStatus::Completed;
}

Implementations

impl ConcurrentState

pub fn new(state: WorkflowState) -> Self

Creates a new ConcurrentState from a WorkflowState.

pub fn read( &self, ) -> Result<RwLockReadGuard<'_, WorkflowState>, PoisonError<RwLockReadGuard<'_, WorkflowState>>>

Acquires a read lock, allowing concurrent access from multiple readers.

Returns

A RwLockReadGuard that provides immutable access to the state.

Panics

Panics if the lock is poisoned (another thread panicked while holding the lock).

pub fn write( &self, ) -> Result<RwLockWriteGuard<'_, WorkflowState>, PoisonError<RwLockWriteGuard<'_, WorkflowState>>>

Acquires a write lock, providing exclusive mutable access.

Returns

A RwLockWriteGuard that provides mutable access to the state.

Panics

Panics if the lock is poisoned (another thread panicked while holding the lock).

pub fn try_read(&self) -> Option<RwLockReadGuard<'_, WorkflowState>>

Attempts to acquire a read lock without blocking.

Returns

• Some(guard) if the lock was acquired immediately
• None if the lock is held by a writer

pub fn try_write(&self) -> Option<RwLockWriteGuard<'_, WorkflowState>>

Attempts to acquire a write lock without blocking.

Returns

• Some(guard) if the lock was acquired immediately
• None if the lock is held by another reader or writer

pub fn ref_count(&self) -> usize

Returns the number of strong references to the inner state.

Useful for debugging to see how many clones exist.

Trait Implementations

impl Clone for ConcurrentState

fn clone(&self) -> ConcurrentState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Send for ConcurrentState

impl Sync for ConcurrentState