Struct executors::crossbeam_workstealing_pool::ThreadPool

pub struct ThreadPool { /* fields omitted */ }

Methods

impl ThreadPool

pub fn new(threads: usize) -> ThreadPool

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::crossbeam_workstealing_pool::ThreadPool;

let pool = ThreadPool::new(4);

Trait Implementations

impl Executor for ThreadPool

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.

impl Default for ThreadPool

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 Clone for ThreadPool

fn clone(&self) -> ThreadPool

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ThreadPool

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

Formats the value using the given formatter.