Struct termusiclib::podcast::Threadpool

pub struct Threadpool { /* private fields */ }

Manages a threadpool of a given size, sending jobs to workers as necessary. Implements Drop trait to allow threads to complete their current jobs before being stopped.

Implementations

impl Threadpool

pub fn new(n_threads: usize) -> Threadpool

Creates a new Threadpool of a given size.

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

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

Adds a new job to the threadpool, passing closure to first available worker.

Panics

if sending commands to the sender fails

Trait Implementations

impl Drop for Threadpool

fn drop(&mut self)

Upon going out of scope, Threadpool sends terminate message to all workers but allows them to complete current jobs.