Struct WorkerController 

pub struct WorkerController<F, V, T, I>
where
    F: Fn(V) -> T + Send + Sync,
    V: Send + Sync,
    T: Send + Sync,
    I: AtomicIterator<AtomicItem = V> + Send + Sized,
{ /* private fields */ }

Implementations

impl<F, V, T, I> WorkerController<F, V, T, I>

where F: Fn(V) -> T + Send + Sync, V: Send + Sync, T: Send + Sync, I: AtomicIterator<AtomicItem = V> + Send + Sized,

pub fn new(f: F, values: I) -> Self

pub fn set_max_threads(&mut self, limit: usize)

pub fn run<C>(&mut self) -> Result<C, WorkThreadError>

where C: Collector<T>,

run function is usually called after WorkerController is instantiated. It is responsible for running the three processes: generate threads and pull from primary queue, redistribute and conquer work amongst threads and join for closure