Struct DenseTransferSchedule 

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

Ordered bounded transfer cursor used by dense streamed execution.

Implementations

impl<T> DenseTransferSchedule<T>

pub fn new( pending: impl IntoIterator<Item = usize>, capacity: usize, ) -> Result<Self, DenseTransferScheduleError>

Creates a cursor over the remaining unit indices.

pub fn has_ready(&self) -> bool

Returns whether at least one submitted transfer is ready for consumption.

pub fn is_exhausted(&self) -> bool

Returns whether no ready or pending units remain.

pub fn can_admit(&self) -> bool

Returns whether another transfer may be admitted into the bounded ready window.

pub fn next_pending(&self) -> Option<usize>

Returns the next unit which must be submitted.

pub fn desired_indices(&self, lookahead: usize) -> Vec<usize>

Returns the current ready indices followed by future indices, truncated to lookahead.

pub fn admit( &mut self, index: usize, transfer: T, ) -> Result<(), DenseTransferScheduleError>

Commits one successfully submitted transfer in exact pending order.

pub fn pop_ready(&mut self) -> Option<(usize, T)>

Removes the oldest ready transfer for execution.

Trait Implementations

impl<T: Debug> Debug for DenseTransferSchedule<T>

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

Formats the value using the given formatter.