Struct SharedPoolMorselScheduler 

pub struct SharedPoolMorselScheduler { /* private fields */ }

Implementations

impl SharedPoolMorselScheduler

pub fn new(pool: SharedExecutorPool) -> Self

pub fn execute<T, F>( &self, admission: &MorselAdmission, execute: F, ) -> Result<Vec<T>>

where T: Send, F: Fn(Morsel) -> Result<T> + Sync,

pub fn execute_with_context<T, F>( &self, admission: &MorselAdmission, context: &RuntimeTaskContext, execute: F, ) -> Result<Vec<T>>

where T: Send, F: Fn(Morsel) -> Result<T> + Sync,

Typed resource failures stop cooperating siblings and preserve the first resource cause. Ordinary callback errors retain input-ordered collection. Use a child context when the parent will be reused for later work.

pub fn execute_accounted_ordered<T, F, C>( &self, admission: &MorselAdmission, resources: MorselStreamResources<'_>, execute: F, consume: C, ) -> Result<MorselStreamReport>

where T: Send, F: Fn(Morsel) -> Result<MorselOutput<T>> + Sync, C: FnMut(Morsel, T) -> Result<MorselStreamControl>,

Streams worker outputs through a bounded channel and invokes the coordinator consumer in stable morsel ordinal order.

output_reservation_bytes is charged before the worker calls execute. The returned resident estimate must fit that reservation. The lease remains live through consume, so a consumer that retains the value must transfer it into another query-owned account.

A terminal typed resource refusal stops dispatch and signals resource exhaustion on task_context before joining in-flight callbacks. Callbacks must check that same context to stop cooperatively. The original resource error is returned. Use a child context to isolate a reusable parent.

Trait Implementations

impl Clone for SharedPoolMorselScheduler

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SharedPoolMorselScheduler

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

Formats the value using the given formatter.