Struct ThreadPool

pub struct ThreadPool<P>
where
    P: SyncThreadPool + Sized,
{ /* private fields */ }

Asynchronous threadpool

Wrapper around a Synchronous threadpool to provide futures support.

Implementations

impl<P> ThreadPool<P>

where P: SyncThreadPool + Sized,

pub fn from_threadpool(pool: P) -> Self

Wraps around an existing threadpool instance

pub fn into_inner(self) -> P

Moves the underlying threadpool out

Trait Implementations

impl<P> AsyncThreadPool for ThreadPool<P>

where P: SyncThreadPool + Sized,

fn new() -> Self

Create a new default thread pool

fn with_thread_count(num_threads: usize) -> Self

Creates a new thread pool with a maximum of num_threads threads

fn execute<F, T>( &self, fun: F, ) -> Pin<Box<dyn Future<Output = T> + Send + Sync + 'static>>

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

Schedules a task on the threadpool

impl<P> Clone for ThreadPool<P>

where P: SyncThreadPool + Sized + Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P> Debug for ThreadPool<P>

where P: SyncThreadPool + Sized + Debug,

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

Formats the value using the given formatter.

impl<P> From<P> for ThreadPool<P>

where P: SyncThreadPool + Sized + Eq,

fn from(p: P) -> Self

Converts to this type from the input type.

impl<P, Rhs> PartialEq<Rhs> for ThreadPool<P>

where P: SyncThreadPool + Sized + PartialEq<Rhs>, Rhs: ?Sized,

fn eq(&self, other: &Rhs) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<P> Eq for ThreadPool<P>

where Self: PartialEq, P: SyncThreadPool + Sized + Eq,