Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Pool managing active workers

Implementations

impl WorkerPool

pub fn new(max_workers: usize) -> WorkerPool

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

The pool reports through a crate::core::report::NoopReporter unless a reporter is attached with WorkerPool::with_reporter.

Arguments

• max_workers - The maximum number of concurrent workers allowed

pub fn with_reporter(self, reporter: Arc<dyn Reporter>) -> WorkerPool

Attach a reporting sink, consuming and returning the pool.

Arguments

• reporter - Sink for progress chatter emitted while the pool drains its workers.

pub async fn execute( &self, task: Box<dyn Task + Sync + Send>, ) -> 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) -> WorkerPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.