Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Pool managing active workers

Implementations

impl WorkerPool

pub fn new(max_workers: usize) -> Self

Creates a new worker pool with the specified maximum number of workers.

Arguments

• max_workers - The maximum number of concurrent workers allowed

pub async fn execute( &self, task: Box<dyn Task + Send + Sync>, ) -> Result<TaskResult, String>

Execute a task by spawning a worker

pub fn get_active_count(&self) -> usize

Number of active workers

pub fn get_capacity(&self) -> usize

Maximum capacity of worker pool

pub fn get_worker_stats(&self) -> WorkerStats

Statistics about current workers

pub async fn shutdown(&self)

Shutdown and wait for all workers

pub fn list_active_workers(&self) -> Vec<ActiveWorkerInfo>

List active worker infos

Trait Implementations

impl Clone for WorkerPool

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.