Struct ExecutionCounters 

pub struct ExecutionCounters { /* private fields */ }

Tracks execution progress for concurrent operations.

This struct uses atomic counters to safely track the number of successful, failed, and completed tasks across concurrent executions.

Examples

use durable_execution_sdk::concurrency::ExecutionCounters;

let counters = ExecutionCounters::new(5);
assert_eq!(counters.total_tasks(), 5);
assert_eq!(counters.success_count(), 0);
assert_eq!(counters.failure_count(), 0);

// Record some completions
counters.complete_task();
counters.complete_task();
counters.fail_task();

assert_eq!(counters.success_count(), 2);
assert_eq!(counters.failure_count(), 1);
assert_eq!(counters.completed_count(), 3);
assert_eq!(counters.pending_count(), 2);

Memory Ordering

The counters use Ordering::Relaxed for increments (only need atomicity) and Ordering::Acquire for loads (need to see latest writes from other threads). Note that reading multiple counters is not atomic - there may be slight inconsistencies between reads, which is acceptable for progress tracking.

Implementations

impl ExecutionCounters

pub fn new(total_tasks: usize) -> Self

Creates a new ExecutionCounters with the given total task count.

pub fn complete_task(&self) -> usize

Records a successful task completion.

Returns the new success count.

Memory Ordering

Uses Ordering::Relaxed for increments - we only need atomicity, not synchronization with other data. The counters are independent values.

Requirements: 4.1, 4.6

pub fn fail_task(&self) -> usize

Records a failed task.

Returns the new failure count.

Memory Ordering

Uses Ordering::Relaxed for increments - we only need atomicity.

Requirements: 4.1, 4.6

pub fn suspend_task(&self) -> usize

Records a suspended task.

Returns the new suspended count.

Memory Ordering

Uses Ordering::Relaxed for increments - we only need atomicity.

Requirements: 4.1, 4.6

pub fn total_tasks(&self) -> usize

Returns the total number of tasks.

Memory Ordering

Uses Ordering::Acquire to ensure we see the latest value written by other threads. This is important for making completion decisions.

Requirements: 4.3, 4.6

pub fn success_count(&self) -> usize

Returns the current success count.

Memory Ordering

Uses Ordering::Acquire to ensure we see the latest value.

Requirements: 4.3, 4.6

pub fn failure_count(&self) -> usize

Returns the current failure count.

Memory Ordering

Uses Ordering::Acquire to ensure we see the latest value.

Requirements: 4.3, 4.6

pub fn completed_count(&self) -> usize

Returns the current completed count (success + failure).

Memory Ordering

Uses Ordering::Acquire to ensure we see the latest value.

Requirements: 4.3, 4.6

pub fn suspended_count(&self) -> usize

Returns the current suspended count.

Memory Ordering

Uses Ordering::Acquire to ensure we see the latest value.

Requirements: 4.3, 4.6

pub fn pending_count(&self) -> usize

Returns the number of pending tasks (not yet completed or suspended).

pub fn is_min_successful_reached(&self, min_successful: usize) -> bool

Checks if the minimum successful count has been reached.

Arguments

• min_successful - The minimum number of successful tasks required

pub fn is_failure_tolerance_exceeded(&self, config: &CompletionConfig) -> bool

Checks if the failure tolerance has been exceeded.

Arguments

• config - The completion configuration with tolerance settings

pub fn should_complete( &self, config: &CompletionConfig, ) -> Option<CompletionReason>

Determines if the operation should complete based on the completion config.

Returns Some(CompletionReason) if the operation should complete, or None if it should continue.

Arguments

• config - The completion configuration

pub fn all_completed(&self) -> bool

Checks if all tasks have completed (success or failure, not suspended).

pub fn has_pending(&self) -> bool

Checks if any tasks are still pending.

Trait Implementations

impl Debug for ExecutionCounters

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

Formats the value using the given formatter.

impl Default for ExecutionCounters

fn default() -> Self

Returns the “default value” for a type.