sync_utils::worker_pool

Trait WorkerPoolInf

Source 
pub trait WorkerPoolInf<M: Send + Sized + Unpin + 'static>: Send + Sync {
    // Required method
    fn submit(&self, msg: M) -> Option<M>;
}

Required Methods§

Source

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

Implementors§

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>,