Struct WorkerPoolBounded 

pub struct WorkerPoolBounded<M: Send + Sized + Unpin + 'static, W: Worker<M>, S: WorkerPoolImpl<M, W>>(/* private fields */);

Implementations

impl<M, W, S> WorkerPoolBounded<M, W, S>

where M: Send + Sized + Unpin + 'static, W: Worker<M>, S: WorkerPoolImpl<M, W>,

pub fn new( inner: S, min_workers: usize, max_workers: usize, channel_size: usize, worker_timeout: Duration, ) -> Self

pub fn set_use_thread(&mut self, ok: bool)

pub fn start(&self)

pub async fn close_async(&self)

pub fn close(&self)

pub fn get_worker_count(&self) -> usize

pub fn get_inner(&self) -> &S

pub fn try_submit(&self, msg: M) -> Option<M>

pub fn submit<'a>(&'a self, msg: M) -> SubmitFuture<'a, M>

Trait Implementations

impl<M, W, S> Clone for WorkerPoolBounded<M, W, S>

where M: Send + Sized + Unpin + 'static, W: Worker<M>, S: WorkerPoolImpl<M, W>,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M, W, S> WorkerPoolAsyncInf<M> for WorkerPoolBounded<M, W, S>

where M: Send + Sized + Unpin + 'static, W: Worker<M>, S: WorkerPoolImpl<M, W>,

fn submit<'life0, 'async_trait>( &'life0 self, msg: M, ) -> Pin<Box<dyn Future<Output = Option<M>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn try_submit(&self, msg: M) -> Option<M>