Struct WorkerPoolUnbounded 

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

Implementations

impl<M, W, S> WorkerPoolUnbounded<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, worker_timeout: Duration, ) -> Self

pub fn get_inner(&self) -> &S

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

pub async fn start(&self)

pub async fn try_spawn(&self, num: usize)

pub async fn close(&self)

pub fn get_worker_count(&self) -> usize

Trait Implementations

impl<M, W, S> Clone for WorkerPoolUnbounded<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> WorkerPoolInf<M> for WorkerPoolUnbounded<M, W, S>

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

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