Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

FFT Worker Pool Manager Simplified to use core parallel abstractions instead of direct ThreadPool management

Implementations

impl WorkerPool

pub fn new() -> Self

Create a new worker pool with default configuration

pub fn with_config( config: WorkerConfig, ) -> Result<Self, Box<dyn Error + Send + Sync>>

Create a new worker pool with custom configuration

pub fn get_workers(&self) -> usize

Get the current number of worker threads

pub fn set_workers( &mut self, num_workers: usize, ) -> Result<(), Box<dyn Error + Send + Sync>>

Set the number of worker threads

Update configuration - actual thread management handled by core parallel abstractions

pub fn is_enabled(&self) -> bool

Check if parallelization is enabled

pub fn set_enabled(&self, enabled: bool)

Enable or disable parallelization

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

where F: FnOnce() -> R + Send, R: Send,

Execute a function in the worker pool if enabled Simplified to use core parallel abstractions

pub fn execute_with_workers<F, R>(&self, _numworkers: usize, f: F) -> R

where F: FnOnce() -> R + Send, R: Send,

Execute a function with a specific number of workers Simplified to use core parallel abstractions

pub fn get_info(&self) -> WorkerPoolInfo

Get information about the worker pool

Trait Implementations

impl Default for WorkerPool

fn default() -> Self

Returns the “default value” for a type.