Struct WorkersPool 

pub struct WorkersPool<W: Worker> { /* private fields */ }

Abstraction of a threadpool for executing units of computation in parallel.

Implementations

impl<W: Worker> WorkersPool<W>

pub fn new(context: W::Context) -> Self

pub fn add_work(&mut self, work: W::Data) -> Result<(), ()>

Adds work to be executed on one of the threads of this pool This function is non-blocking

pub fn receive_result(&mut self) -> Result<W::Result, ()>

Receives the result of a computation This function blocks until a result is available or all threads have panicked

pub fn try_receive_result(&mut self) -> Result<Option<W::Result>, ()>

Tries to receive the result of a computation This function does not block if no result is available but rather returns Ok(None)

pub fn collect_finished(&mut self) -> Result<Vec<W::Result>, ()>

Collects all available results

pub fn has_work_left(&self) -> bool

Checks if any work is left in the work queue

Note: An empty work queue does not mean that none of the worker threads is still busy

pub fn has_results(&self) -> bool

Checks if there are results available