Struct DispatchQueue 

pub struct DispatchQueue<T> { /* private fields */ }

Deterministic FIFO dispatch queue for attempt coordination.

Invariants

• Intake is bounded to capacity.
• Dequeue order is deterministic FIFO.
• Shutdown state is explicit and inspectable.
• This type does not apply execution or retry policy.

Implementations

impl<T> DispatchQueue<T>

pub fn new(capacity: NonZeroUsize) -> Self

Creates a dispatch queue with bounded intake capacity.

pub fn enqueue(&mut self, item: T) -> Result<(), DispatchQueueError>

Enqueues one work item.

Returns:

• DispatchQueueError::Shutdown if the dispatch queue has been closed.
• DispatchQueueError::Backpressure if queue capacity is already reached.

pub fn dequeue(&mut self) -> Result<Option<T>, DispatchQueueError>

Dequeues one work item in deterministic FIFO order.

Returns DispatchQueueError::Shutdown only when the dispatch queue has been shut down and no queued work remains.

pub fn shutdown(&mut self)

Marks the dispatch queue as shut down.

After shutdown:

• New intake is rejected.
• Existing queued items remain available to be drained in FIFO order.

pub fn capacity(&self) -> usize

Returns queue capacity.

pub fn len(&self) -> usize

Returns queued item count.

pub fn is_empty(&self) -> bool

Returns true when no items are queued.

pub fn is_shutdown(&self) -> bool

Returns true when dispatch queue has been marked shut down.

Trait Implementations

impl<T: Debug> Debug for DispatchQueue<T>

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

Formats the value using the given formatter.