Struct ThreadPool 

pub struct ThreadPool {
    pub workers: Vec<WorkerThread>,
    pub task_queue: Arc<Mutex<VecDeque<Task>>>,
    pub statistics: ThreadPoolStatistics,
}

Thread pool implementation

Fields

workers: Vec<WorkerThread>

Worker threads

task_queue: Arc<Mutex<VecDeque<Task>>>

Task queue

statistics: ThreadPoolStatistics

Thread pool statistics

Implementations

impl ThreadPool

pub fn new(size: usize) -> Self

Create a new thread pool

pub fn worker_count(&self) -> usize

Get the number of workers

pub fn pending_tasks(&self) -> usize

Get pending task count

Trait Implementations

impl Debug for ThreadPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.