Struct pconvert_rust::parallelism::ThreadPool

pub struct ThreadPool { /* fields omitted */ }

Thread pool used in multi-threaded pconvert calls.

Implementations

impl ThreadPool

pub fn new(size: usize) -> Result<ThreadPool, PConvertError>

Creates a thread pool with size worker threads.

pub fn start(&mut self)

Begin execution of worker threads.

pub fn execute<F>(&self, func: F) -> Receiver<ResultMessage> where
    F: FnOnce() -> ResultMessage + Send + 'static, 

Enqueues a task for execution by any of the worker threads.

Arguments

• func - The task to execute.

Return

Returns the receiver end of a channel where the result will be placed.

Examples

let result_channel = thread_pool.execute(move || ResultMessage::ImageResult(read_png_from_file(top_path, demultiply)));
let top = match result_channel.recv().unwrap() {
    ResultMessage::ImageResult(result) => result,
}.unwrap();

pub fn expand_to(&mut self, num_threads: usize)

Expands the thread pool to num_threads. Creates n workers, where n = num_threads - thread_pool_size.

pub fn get_status(&self) -> ThreadPoolStatus

Trait Implementations

impl Drop for ThreadPool

pub fn drop(&mut self)

Executes the destructor for this type.