Class LoopExecutor

java.lang.Object

ai.nervemind.app.executor.LoopExecutor

All Implemented Interfaces:

NodeExecutor

@Component
public class LoopExecutor
extends Object
implements NodeExecutor

Executor for the "loop" node type - iterates over arrays or collections.

Enables processing of multiple items by iterating through a collection and executing child operations for each item. Supports both sequential and parallel execution modes using Java virtual threads.

Node Parameters

Loop node configuration parameters

Parameter	Type	Default	Description
items	String	"items"	Field name containing the array to iterate
parallel	Boolean	false	Enable virtual thread parallelism
batchSize	Integer	10	Items processed concurrently when parallel=true

Output Data

Output keys added by this executor

Key	Type	Description
results	List	List of result objects, each with "item" and "index"
count	Integer	Number of items processed

Result Item Structure

Each item in the results list contains:

• item - The original item from the input array
• index - Zero-based index of the item in the original array

Parallel Execution

When parallel=true, items are processed using virtual threads (requires Java 21+). The batch size controls how many virtual threads are spawned concurrently:

// Configuration for parallel processing with batches of 5
{
"parallel": true,
"batchSize": 5,
"items": "dataArray"
}

See Also:

• For branch-based parallel execution
• Executors.newVirtualThreadPerTaskExecutor()

Constructor Summary

Constructors

Constructor	Description
LoopExecutor()	Default constructor.

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	execute(ai.nervemind.common.domain.Node node, Map<String,Object> input, ExecutionService.ExecutionContext context)	Executes the business logic for this node type.
String	getNodeType()	Unique identifier for the node type this executor handles.

Methods inherited from class Object

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

Constructor Details

LoopExecutor

public LoopExecutor()

Default constructor.

Method Details

execute

public Map<String,Object> execute(ai.nervemind.common.domain.Node node,
 Map<String,Object> input,
 ExecutionService.ExecutionContext context)

Description copied from interface: NodeExecutor

Executes the business logic for this node type.

Specified by:

execute in interface NodeExecutor

Parameters:

node - The node definition containing parameters and configuration. Use Node.parameters() to access user settings.

input - Combined output from all upstream nodes that connected to this node. For simple flows, this contains the direct predecessor's output. For merge nodes, it contains combined data.

context - Verification context providing access to workflow-scoped services, logger, and execution metadata.

Returns:

A Map containing the results of this node's execution. Keys in this map become available variables for downstream nodes.
Note: Returning null is treated as an empty map.

getNodeType

public String getNodeType()

Description copied from interface: NodeExecutor

Unique identifier for the node type this executor handles. This must match the 'type' field in the JSON definition of the node.

Specified by:

getNodeType in interface NodeExecutor

Returns:

The unique type string (e.g., "httpRequest", "llmChat").