Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

A pool of shared resources, each of which can only be used once at a time.

Implementations

impl Pool

pub fn new(capacity: usize) -> Pool

Create a new pool of capacity items, using factory to generate new items.

pub async fn run<Context, F>( &self, context: Context, code: impl FnOnce(Context) -> F + Send + 'static, ) -> Guard<Task<<F as Future>::Output>>

where Context: Post, F: Future + 'static, <F as Future>::Output: Post,

Run a job, creating a new thread if necessary or waiting for one to become available.

pub async fn run_send<Context, F>( &self, context: Context, code: impl FnOnce(Context) -> F + Send + 'static, ) -> Guard<SendTask<<F as Future>::Output>>

where Context: Post, F: Future + 'static, <F as Future>::Output: Send,

Like Pool::run, but the output can be sent through Rust memory without Posting.