Struct ThreadPool

pub struct ThreadPool { /* private fields */ }

Thread pool of workers awaiting execution orders.

Implementations

impl ThreadPool

pub fn new(capacity: usize) -> ThreadPool

Create a new ThreadPool.

The capacity is the number of desired threads in the pool.

Panics

The new function will panic if the capacity is zero.

Examples

use std::sync::Arc;
use std::sync::atomic::{ Ordering, AtomicBool };
use threaded::ThreadPool;

let num_workers = 2;
let tp = ThreadPool::new(num_workers);

assert_eq!(tp.capacity(), num_workers);

let has_executed = Arc::new(AtomicBool::new(false));
{
    let has_executed = has_executed.clone();
    tp.execute(move || {
        has_executed.swap(true, Ordering::SeqCst);
    });
}

drop(tp); // block main thread until execute finishes (uses handle.join())

assert_eq!(has_executed.load(Ordering::SeqCst), true);

pub fn capacity(&self) -> usize

Capacity of thread pool (number of workers).

pub fn resize(&mut self, capacity: usize)

Resize thread pool to new capacity

Panics

The resize function will panic if the capacity is zero.

Caution: Dead workers aren’t removed from pool wasting memory but is fault tolerant.

pub fn execute<F>(&self, f: F)

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

Execute function/closure using worker from thread pool.

Trait Implementations

impl Drop for ThreadPool

fn drop(&mut self)

Executes the destructor for this type.