Struct BatchExecutor 

pub struct BatchExecutor<P: LlmProvider + 'static> { /* private fields */ }

Executes multiple tasks through an agent with controlled concurrency.

Unlike ParallelAgent which runs different agents on the same task, BatchExecutor runs the SAME agent on different tasks with a concurrency limit.

Implementations

impl<P: LlmProvider + 'static> BatchExecutor<P>

pub fn builder(agent: AgentRunner<P>) -> BatchExecutorBuilder<P>

Create a new builder for BatchExecutor.

pub async fn execute(&self, tasks: Vec<String>) -> Vec<BatchResult>

Execute all tasks with controlled concurrency. Returns results for ALL tasks (successes and failures). Results are sorted by input index.

pub async fn execute_ref(&self, tasks: &[&str]) -> Vec<BatchResult>

Convenience: execute with string slice references.

pub fn aggregate_usage(results: &[BatchResult]) -> TokenUsage

Returns aggregate token usage across all successful executions.

Trait Implementations

impl<P: LlmProvider + 'static> Debug for BatchExecutor<P>

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

Formats the value using the given formatter.