Package com.alibaba.cloud.ai.graph.agent.flow.agent

Class ParallelAgent

java.lang.Object

com.alibaba.cloud.ai.graph.agent.Agent

com.alibaba.cloud.ai.graph.agent.flow.agent.FlowAgent

com.alibaba.cloud.ai.graph.agent.flow.agent.ParallelAgent

public class ParallelAgent
extends FlowAgent

ParallelAgent executes multiple sub-agents in parallel and merges their results.

This agent implements the Parallel Fan-Out/Gather pattern where:

• Fan-Out: The input is distributed to all sub-agents simultaneously
• Parallel Execution: All sub-agents execute concurrently
• Gather: Results from all sub-agents are collected and merged

The agent leverages the underlying ParallelNode infrastructure to achieve true parallel execution and provides configurable result merging strategies.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ParallelAgent.ConcatenationMergeStrategy	Concatenation merge strategy for string results.
static class	ParallelAgent.DefaultMergeStrategy	Default merge strategy that combines all results into a map.
static class	ParallelAgent.ListMergeStrategy	List merge strategy that combines results into a list.
static interface	ParallelAgent.MergeStrategy	Strategy interface for merging parallel execution results.
static class	ParallelAgent.ParallelAgentBuilder	Builder for creating ParallelAgent instances.

Field Summary

Fields inherited from class com.alibaba.cloud.ai.graph.agent.flow.agent.FlowAgent

hooks, interruptBefore, stateSerializer, subAgents

Fields inherited from class com.alibaba.cloud.ai.graph.agent.Agent

compileConfig, compiledGraph, description, executor, graph, name

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ParallelAgent(ParallelAgent.ParallelAgentBuilder builder)

Method Summary

Modifier and Type	Method	Description
static ParallelAgent.ParallelAgentBuilder	builder()
protected RunnableConfig	buildNonStreamConfig(RunnableConfig config)	Override buildNonStreamConfig to add maxConcurrency to RunnableConfig metadata.
protected StateGraph	buildSpecificGraph(FlowGraphBuilder.FlowGraphConfig config)	Abstract method for subclasses to specify their graph building strategy.
protected RunnableConfig	buildStreamConfig(RunnableConfig config)	Override buildStreamConfig to add maxConcurrency to RunnableConfig metadata.
Integer	maxConcurrency()	Gets the maximum concurrency limit for this ParallelAgent.
String	mergeOutputKey()
ParallelAgent.MergeStrategy	mergeStrategy()	Gets the merge strategy used by this ParallelAgent.

Methods inherited from class com.alibaba.cloud.ai.graph.agent.flow.agent.FlowAgent

asStateGraph, hooks, initGraph, schedule, subAgents

Methods inherited from class com.alibaba.cloud.ai.graph.agent.Agent

applyExecutorConfig, buildMessageInput, description, doInvoke, doInvokeAndGetOutput, doStream, getAndCompileGraph, getCurrentState, getGraph, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, invokeAndGetOutput, name, schedule, stream, stream, stream, stream, stream, stream, stream, stream, streamMessages, streamMessages, streamMessages, streamMessages, streamMessages, streamMessages, streamMessages, streamMessages

Methods inherited from class java.lang.Object

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

Constructor Details

ParallelAgent

protected ParallelAgent(ParallelAgent.ParallelAgentBuilder builder)

Method Details

builder

public static ParallelAgent.ParallelAgentBuilder builder()

buildSpecificGraph

protected StateGraph buildSpecificGraph(FlowGraphBuilder.FlowGraphConfig config)
                                 throws GraphStateException

Description copied from class: FlowAgent

Abstract method for subclasses to specify their graph building strategy. This method should be implemented by concrete FlowAgent subclasses to define how their specific graph structure should be built.

Specified by:

buildSpecificGraph in class FlowAgent

Parameters:

config - the graph configuration

Returns:

the constructed StateGraph

Throws:

GraphStateException - if graph construction fails

mergeStrategy

public ParallelAgent.MergeStrategy mergeStrategy()

Gets the merge strategy used by this ParallelAgent.

Returns:

the merge strategy

mergeOutputKey

public String mergeOutputKey()

maxConcurrency

public Integer maxConcurrency()

Gets the maximum concurrency limit for this ParallelAgent.

Returns:

the max concurrency, or null if unlimited

buildNonStreamConfig

protected RunnableConfig buildNonStreamConfig(RunnableConfig config)

Override buildNonStreamConfig to add maxConcurrency to RunnableConfig metadata. This allows the ParallelNode to access the concurrency limit during execution.

Overrides:

buildNonStreamConfig in class Agent

buildStreamConfig

protected RunnableConfig buildStreamConfig(RunnableConfig config)

Override buildStreamConfig to add maxConcurrency to RunnableConfig metadata. This allows the ParallelNode to access the concurrency limit during execution.

Overrides:

buildStreamConfig in class Agent