Package com.tnsai.quality.validation.parallel

Class ParallelValidationExecutor

java.lang.Object

com.tnsai.quality.validation.parallel.ParallelValidationExecutor

public class ParallelValidationExecutor
extends Object

Executes the same task across multiple agents for validation and comparison.

Parallel validation allows running the same prompt through different LLM models to validate responses, find consensus, identify divergences, and select the best solution based on various aggregation strategies.

Use Cases

• Code review validation: 3 models review → common issues = high confidence
• Critical refactoring: Compare different approaches from different models
• Decision validation: Ensure consensus on important decisions

Usage

 ParallelValidationExecutor executor = ParallelValidationExecutor.builder()
     .addAgent(claudeAgent)
     .addAgent(geminiAgent)
     .addAgent(ollamaAgent)
     .aggregationStrategy(AggregationStrategy.CONSENSUS)
     .timeout(Duration.ofSeconds(60))
     .build();

 ValidationResult result = executor.execute("Review this code for security issues");

 // Access results
 result.getBestSolution();      // Best response based on strategy
 result.getConsensusPoints();   // Points all agents agree on
 result.getDivergences();       // Points where agents disagree
 result.getMetrics();           // Execution metrics
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ParallelValidationExecutor.Builder

Method Summary

Modifier and Type	Method	Description
static ParallelValidationExecutor.Builder	builder()
ValidationResult	execute(String prompt)	Executes the prompt across all configured agents/LLMs.
CompletableFuture<ValidationResult>	executeAsync(String prompt)	Executes asynchronously.
int	getParticipantCount()	Gets the number of participants.
AggregationStrategy	getStrategy()	Gets the configured aggregation strategy.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builder

public static ParallelValidationExecutor.Builder builder()

execute

public ValidationResult execute(String prompt)

Executes the prompt across all configured agents/LLMs.

Parameters:

prompt - the prompt to execute

Returns:

validation result with aggregated response and metrics

executeAsync

public CompletableFuture<ValidationResult> executeAsync(String prompt)

Executes asynchronously.

getStrategy

public AggregationStrategy getStrategy()

Gets the configured aggregation strategy.

getParticipantCount

public int getParticipantCount()

Gets the number of participants.