Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

A basic Thread Pool

Examples

use std::thread;
use std::time::Duration;
use xuko_core::thread_pool::ThreadPool;

let mut pool = ThreadPool::new(8);
for i in 0..pool.capacity() {
    let v = (i + 1) as u64;
    pool.enqueue(move || {
        thread::sleep(Duration::from_secs(v));
        println!("Task finished! {v}")
    });
}
// blocks until all threads in the pool finish
pool.run_all();

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)

Blocks until all the active threads to finish and the queue is empty