Struct ThreadPool

pub struct ThreadPool {
    pub workers: Vec<Worker>,
    pub sender: Sender<Box<dyn FnOnce() + Send + 'static>>,
}

ThreadPool

ThreadPool - Struct representing a thread pool.

Example

Create an instance of ThreadPool:

 
let pool = ThreadPool::new(10);

This will create 10 workers (threads).

Than you will able to use execute method, which will start task execution.

And since this method gets a closure or a regular function in the parameter:

#1

pool.execute(|| { 
    println!("Yoo!"); 
});
  

#2

pool.execute(some_function);

Fields

workers: Vec<Worker>

sender: Sender<Box<dyn FnOnce() + Send + 'static>>

Implementations

impl ThreadPool

pub fn new(size: usize) -> Self

Creates a new thread pool with the specified size.

Arguments

• size - The number of threads in the thread pool.

Panics

Panics if the size is 0.

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

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

Executes a job in the thread pool.

Arguments

• f - The closure or function representing the job to be executed.

Example

let pool = ThreadPool::new(4);

pool.execute(move || {
    println!("Working on a job");
});