Struct thread_manager::ThreadManager

pub struct ThreadManager<T>
where
    T: Send + 'static,
{ /* private fields */ }

Implementations

impl<T> ThreadManager<T>

where T: Send + 'static,

pub fn new(size: usize) -> Self

pub fn new_asymmetric(size: usize, wpc: usize) -> Self

pub fn execute<F>(&self, function: F)

where F: Fn() -> T + Send + 'static,

pub fn resize(&mut self, size: usize)

pub fn join(&self)

pub fn terminate_all(&self)

pub fn job_distribution(&self) -> Vec<usize>

pub fn has_finished(&self) -> bool

pub fn results<'a>(&'a self) -> ResultIter<'a, T>

pub fn yield_results<'a>( &'a self ) -> YieldResultIter<'a, Box<dyn Fn() -> T + Send + 'static>, T>

pub fn active_threads(&self) -> usize

pub fn busy_threads(&self) -> usize

pub fn waiting_threads(&self) -> usize

pub fn job_queue(&self) -> usize

pub fn sent_jobs(&self) -> usize

pub fn received_jobs(&self) -> usize

pub fn concluded_jobs(&self) -> usize