Struct ThreadPool

pub struct ThreadPool(/* private fields */);

Implementations

impl ThreadPool

pub fn shared(max_threads: Option<u32>) -> Result<ThreadPool, Error>

pub fn exclusive(max_threads: u32) -> Result<ThreadPool, Error>

pub fn push<T, F>(&self, func: F) -> Result<ThreadHandle<T>, Error>

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

pub fn push_future<T, F>( &self, func: F, ) -> Result<impl Future<Output = Result<T, Box<dyn Any + Send>>> + Send + Sync + 'static, Error>

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

pub fn set_max_threads(&self, max_threads: Option<u32>) -> Result<(), Error>

pub fn max_threads(&self) -> Option<u32>

pub fn num_threads(&self) -> u32

pub fn unprocessed(&self) -> u32

pub fn set_max_unused_threads(max_threads: Option<u32>)

pub fn max_unused_threads() -> Option<u32>

pub fn num_unused_threads() -> u32

pub fn stop_unused_threads()

pub fn set_max_idle_time(max_idle_time: u32)

pub fn max_idle_time() -> u32

Trait Implementations

impl Debug for ThreadPool

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

Formats the value using the given formatter.

impl Drop for ThreadPool

fn drop(&mut self)

Executes the destructor for this type.

impl Send for ThreadPool

impl Sync for ThreadPool