Struct ParallelStrategy 

pub struct ParallelStrategy { /* private fields */ }

Parallel execution strategy - executes tasks concurrently

Implementations

impl ParallelStrategy

pub fn new(max_concurrent_tasks: usize) -> Self

Trait Implementations

impl Default for ParallelStrategy

fn default() -> Self

Returns the “default value” for a type.

impl ExecutionStrategy for ParallelStrategy

fn name(&self) -> &'static str

Strategy name

fn description(&self) -> &'static str

Strategy description

fn execute_task( &self, task: ExecutionTask, ) -> Pin<Box<dyn Future<Output = SklResult<TaskResult>> + Send + '_>>

Execute a single task

fn execute_batch( &self, tasks: Vec<ExecutionTask>, ) -> Pin<Box<dyn Future<Output = SklResult<Vec<TaskResult>>> + Send + '_>>

Execute multiple tasks

fn get_config(&self) -> StrategyConfig

Get strategy configuration

fn update_config(&mut self, config: StrategyConfig) -> SklResult<()>

Update strategy configuration

fn get_metrics(&self) -> StrategyMetrics

Get strategy metrics

fn health_check(&self) -> StrategyHealth

Check strategy health