Struct QueuedArrayCounter 

pub struct QueuedArrayCounter { /* private fields */ }

Tracks the number of queued (in-flight) arrays across non-blocking plugins. Used by drivers to perform a bounded wait at end of acquisition.

Implementations

impl QueuedArrayCounter

pub fn new() -> Self

Create a new counter starting at zero.

pub fn increment(&self)

Increment the queued count (called before try_send).

pub fn decrement(&self)

Decrement the queued count. Notifies waiters when reaching zero.

pub fn get(&self) -> usize

Current queued count.

pub fn wait_until_zero(&self, timeout: Duration) -> bool

Wait until count reaches zero, or timeout expires. Returns true if count is zero, false on timeout.

Trait Implementations

impl Default for QueuedArrayCounter

fn default() -> Self

Returns the “default value” for a type.