Struct WorkerPool

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

Implementations

impl<M, W, S> WorkerPool<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, buffer_size: usize, worker_timeout: Duration, rt: &Runtime, ) -> Self

pub fn get_inner(&self) -> &S

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

pub fn close(&self)

pub fn get_worker_count(&self) -> usize

Trait Implementations

impl<M, W, S> Clone for WorkerPool<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.