Struct Pool 

pub struct Pool<I, O>
where
    I: Send + 'static,
    O: Send + Clone + 'static,
{ /* private fields */ }

A bounded async worker pool.

Implementations

impl<I, O> Pool<I, O>

where I: Send + 'static, O: Send + Clone + 'static,

pub fn new(handler: Arc<dyn Handler<I, O>>, config: PoolConfig) -> Self

Create a new pool backed by handler.

config.size is clamped to a minimum of 1 (a zero-sized pool can never execute tasks because no permits would be available); a tracing warn is emitted when this clamp engages.

pub async fn submit(&self, input: I) -> AppResult<TaskHandle<O>>

Submit a task; returns a TaskHandle immediately.

pub fn stats(&self) -> PoolStats

Snapshot of pool activity.

pub fn available_permits(&self) -> usize

Number of permits currently available for task execution.

pub fn close(&self)

Stop accepting work and ask the runner loop to exit.

pub async fn shutdown(self) -> AppResult<()>

Cancel all in-flight tasks and shut down the runner loop.

Trait Implementations

impl<I, O> Drop for Pool<I, O>

where I: Send + 'static, O: Send + Clone + 'static,

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.