Struct BlockingExecutor 

pub struct BlockingExecutor { /* private fields */ }

A bounded, lazily started executor for synchronous work.

Clones share one pool. Dropping the last executor or calling shutdown rejects new submissions and fails waiting jobs; running jobs may finish. The default limits use the available CPU count and four waiting jobs per CPU. Web submissions return Unsupported without executing the closure.

Implementations

impl BlockingExecutor

pub fn new(config: BlockingExecutorConfig) -> Self

Creates an executor without starting threads or reserving queue storage.

pub fn try_submit<T, F>( &self, work: F, ) -> Result<BlockingTask<T>, BlockingError>

where T: Send + 'static, F: FnOnce() -> T + Send + 'static,

Admits work without waiting for capacity, or returns Saturated.

The returned future owns the job: dropping it removes waiting work and releases its captures. A job already taken by a worker may finish.

pub async fn submit<T, F>(&self, work: F) -> Result<T, BlockingError>

where T: Send + 'static, F: FnOnce() -> T + Send + 'static,

Waits asynchronously for queue capacity, then runs work and returns its result.

A full queue suspends this future without blocking its polling thread or returning Saturated. Dropping the future cancels admission or queued work. Each suspended caller retains its closure until admission or cancellation; applications should bound the number of concurrent producer tasks.

pub fn shutdown(&self)

Stops admission and resolves waiting jobs with Shutdown. Does not wait for or interrupt running closures.

Trait Implementations

impl Clone for BlockingExecutor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for BlockingExecutor

fn default() -> Self

Returns the “default value” for a type.