Struct Threadpool

pub struct Threadpool { /* private fields */ }

Implementations

impl Threadpool

pub fn new(workers: usize) -> Self

Create a new thread pool.

pub async fn spawn<F, R>(&self, func: F) -> R

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

Queue a new command for execution on this pool.

pub fn spawn_local<'pool, F, R>( &'pool self, func: F, ) -> SpawnFuture<'pool, F, R>

where F: FnOnce() -> R + Send + 'pool, R: Send + 'pool,

Queue a new command for execution on this pool with access to the local variables.

The future of this function will block the current thread if it is not fully completed.

pub fn build_global(self) -> Result<(), Error>

Set this threadpool as the global threadpool.

pub fn thread_count(&self) -> usize

Get the total number of worker threads in this pool.

pub fn num_threads(&self) -> usize

Get the specified number of threads for this pool.

Trait Implementations

impl Debug for Threadpool

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

Formats the value using the given formatter.

impl Default for Threadpool

fn default() -> Self

Returns the “default value” for a type.