Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

Thread pool struct.

Panics

Panics when the generic parameter (POOL_SIZE) is zero.

Example

use std::thread;
use std::time;

use swimming_pool::ThreadPool;

fn main() {
    // Initialize a thread pool with 5 threads
    let pool = ThreadPool::new(5);

    pool.execute(|| {
        // Send job to the pool
        thread::sleep(time::Duration::from_secs(5));
    });

    pool.join_all();
}

Implementations

impl ThreadPool

pub fn new(size: usize) -> Self

Initialize a new thread pool

Panics

Panics when the generic parameter (POOL_SIZE) is zero.

pub fn execute<F: FnOnce() + Send + 'static>(&self, f: F)

Send a job to the pool. This job will be picked and executed by any free woker thread.

Example

use threadpool::Threadpool;

let pool = ThreadPool::new(10);
pool.execute(|| {
    // Send job to the pool
});

pub fn join_all(self)

Join all the worker threads (wait for them to finish executing their job).

pub fn get_pool_size(&self) -> usize

Returns the number of worker threads in the thread pool.

pub fn get_working_threads(&self) -> usize

Returns the number of woker threads which are currently executing a job.