Struct ThreadPoolExecutor 

pub struct ThreadPoolExecutor { /* private fields */ }

A handle to a threadpool_executor

See module level documentation for usage information.

Implementations

impl ThreadPoolExecutor

pub fn new(threads: usize) -> ThreadPoolExecutor

Creates a new thread pool capable of executing threads number of jobs concurrently.

Panics

This function will panic if threads is 0.

Examples

Create a new thread pool capable of executing four jobs concurrently:

use executors::*;
use executors::threadpool_executor::ThreadPoolExecutor;

let pool = ThreadPoolExecutor::new(4);

Trait Implementations

impl CanExecute for ThreadPoolExecutor

fn execute_job(&self, job: Box<dyn FnOnce() + Send + 'static>)

Executes the function job on the Executor.

impl Clone for ThreadPoolExecutor

fn clone(&self) -> ThreadPoolExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ThreadPoolExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ThreadPoolExecutor

Create a thread pool with one thread per CPU. On machines with hyperthreading, this will create one thread per hyperthread.

fn default() -> Self

Returns the “default value” for a type.

impl Executor for ThreadPoolExecutor

fn execute<F>(&self, job: F)

where F: FnOnce() + Send + 'static,

Executes the function job on the Executor.

fn shutdown_async(&self)

Shutdown the Executor without waiting.

fn shutdown_borrowed(&self) -> Result<(), String>

Same as shutdown but without consuming self

fn shutdown(self) -> Result<(), String>

Shutdown an Executor and wait for it to shut down all workers.