Struct ThreadpoolRuntime 

pub struct ThreadpoolRuntime { /* private fields */ }

Available on crate feature std only.

A running threadpool with priority lanes (RT-CORBA §5.7).

Implementations

impl ThreadpoolRuntime

pub fn start<M: PriorityMapping>( pool: &Threadpool, mapping: &M, hook: Option<Arc<dyn NativePrioritySetter>>, ) -> Self

Starts a threadpool: creates static_threads workers per lane.

mapping maps the lane priority to the native priority that is passed to the hook (if set) per worker.

pub fn dispatch<F>( &self, priority: Priority, job: F, ) -> Result<(), DispatchError>

where F: FnOnce() + Send + 'static,

Hands a job to the lane of its priority. Wakes a waiting worker or creates — under saturation with free dynamic budget — a dynamic worker.

Errors

DispatchError::NoLane on an empty pool; DispatchError::Rejected if no worker is free and buffering is off or the buffer is full.

pub fn lane_count(&self) -> usize

Number of lanes.

pub fn spawned_workers(&self, lane_index: usize) -> usize

Number of currently alive workers of a lane (static + dynamic), derived from the stored handles. Primarily for tests/telemetry.

Panics

On a poisoned internal lock.

Trait Implementations

impl Drop for ThreadpoolRuntime

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.