Struct ParallelController 

pub struct ParallelController { /* private fields */ }

Adaptive parallelism controller with backpressure

Implementations

impl ParallelController

pub fn new(config: ParallelConfig) -> Self

Create a new parallel controller

pub async fn process_parallel<T, F, Fut, R>( &self, items: Vec<WorkItem<T>>, processor: F, ) -> Vec<Result<R, String>>

where T: Send + Sync + Clone + 'static, F: Fn(T) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = Result<R, String>> + Send + 'static, R: Send + 'static,

Process work items with adaptive parallelism and backpressure

pub fn metrics(&self) -> ParallelMetrics

Get current performance metrics

pub fn reset_metrics(&self)

Reset metrics

Trait Implementations

impl Debug for ParallelController

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

Formats the value using the given formatter.