Struct backup_deduplicator::threadpool::ThreadPool

pub struct ThreadPool<Job, Result>
where
    Job: Send,
    Result: Send,
{ /* private fields */ }

Implementations

impl<Job: Send + JobTrait + 'static, Result: Send + ResultTrait + 'static> ThreadPool<Job, Result>

pub fn new<Argument: Send + 'static>( args: Vec<Argument>, func: fn(_: usize, _: Job, _: &Sender<Result>, _: &Sender<Job>, _: &mut Argument) ) -> ThreadPool<Job, Result>

pub fn publish(&self, job: Job)

pub fn receive(&self) -> Result<Result, RecvError>

pub fn receive_timeout( &self, timeout: Duration ) -> Result<Result, RecvTimeoutError>

Trait Implementations

impl<Job: Send, Result: Send> Drop for ThreadPool<Job, Result>

fn drop(&mut self)

Executes the destructor for this type.