Struct Scheduler 

pub struct Scheduler<P> { /* private fields */ }

Pipeline scheduler that manages batch submission and interleaving.

The scheduler doesn’t own backends directly — instead, callers use Scheduler::next_batch to get the next group of items to submit, then handle submission/polling themselves. This keeps the scheduler backend-agnostic and testable.

Implementations

impl<P> Scheduler<P>

pub fn new(config: SchedulerConfig) -> Self

Create a new scheduler with the given configuration.

pub fn enqueue(&mut self, items: impl IntoIterator<Item = WorkItem<P>>)

Add work items to the scheduler’s queue.

pub fn pending_count(&self) -> usize

Number of items currently in the queue.

pub fn is_empty(&self) -> bool

Returns true if the queue is empty.

pub fn next_batch(&mut self) -> Option<Vec<BatchGroup<P>>>

Take the next batch of work items from the queue, grouped optimally.

Returns None if the queue is empty. Otherwise returns a vec of BatchGroups, each containing items that should be submitted together for optimal cache utilization.

Items past max_wait are promoted into this batch regardless of grouping optimality.