Struct ParallelExecutor 

pub struct ParallelExecutor { /* private fields */ }

Parallel execution engine for agents

Implementations

impl ParallelExecutor

pub fn new() -> Self

Create a new parallel executor with default configuration

pub fn with_config(config: ExecutionConfig) -> Self

Create a new parallel executor with custom configuration

pub async fn execute_phase( &self, phase: &ExecutionPhase, ) -> Result<Vec<ExecutionResult>>

Execute a phase of tasks in parallel

pub fn config(&self) -> &ExecutionConfig

Get the current configuration

pub fn set_config(&mut self, config: ExecutionConfig)

Update the configuration

pub fn set_max_concurrency(&mut self, max_concurrency: usize)

Set the maximum concurrency

pub fn set_timeout_ms(&mut self, timeout_ms: u64)

Set the timeout for tasks

pub fn set_verbose(&mut self, verbose: bool)

Enable or disable verbose logging

Trait Implementations

impl Default for ParallelExecutor

fn default() -> Self

Returns the “default value” for a type.