Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

A basic Thread Pool

Implementations

impl ThreadPool

pub fn new(size: usize) -> Self

Create a new ThreadPool.

pub fn enqueue(&mut self, worker: impl Worker)

Enqueue a Worker to the ThreadPool.

pub fn update_threads(&mut self) -> bool

Removes threads from the pool once they’re finished and spawn new ones from the queue.

Returns true if the pool is empty even after emptying the queue.

pub const fn capacity(&self) -> usize

Gets the capacity of the ThreadPool.

pub fn queued_count(&self) -> usize

Returns the amount of enqueued Workers.

pub const fn active_count(&self) -> usize

Returns the amount of running threads.

pub fn is_finished(&self) -> bool

Returns true when both the queue and pool are empty.

pub fn run_all(&mut self)

Wait for all the active threads to finish until the queue is empty