程序包 dev.tinyflow.core.chain.runtime

类 ChainExecutor

java.lang.Object

dev.tinyflow.core.chain.runtime.ChainExecutor

public class ChainExecutor
extends Object

TinyFlow 最新 ChainExecutor

说明: * 负责触发 Chain 执行 / 恢复 * 不持有长时间运行的 Chain 实例 * 支持 async-only 架构

字段概要

字段

修饰符和类型	字段	说明
private final ChainStateRepository	chainStateRepository
private final ChainDefinitionRepository	definitionRepository
private final EventManager	eventManager
private final NodeStateRepository	nodeStateRepository
private final TriggerScheduler	triggerScheduler

构造器概要

构造器

构造器	说明
ChainExecutor(ChainDefinitionRepository definitionRepository, ChainStateRepository chainStateRepository, NodeStateRepository nodeStateRepository)
ChainExecutor(ChainDefinitionRepository definitionRepository, ChainStateRepository chainStateRepository, NodeStateRepository nodeStateRepository, TriggerScheduler triggerScheduler)

方法概要

修饰符和类型	方法	说明
private void	accept(Trigger trigger, ExecutorService worker)
void	addErrorListener(ChainErrorListener listener)
void	addEventListener(ChainEventListener listener)
void	addEventListener(Class<? extends Event> eventClass, ChainEventListener listener)
void	addNodeErrorListener(NodeErrorListener listener)
void	addOutputListener(ChainOutputListener outputListener)
void	clearDefaultStates(Map<String,Object> result)	清理默认状态
private Chain	createChain(String definitionId)
Map<String,Object>	execute(String definitionId, Map<String,Object> variables)
Map<String,Object>	execute(String definitionId, Map<String,Object> variables, long timeout, TimeUnit unit)
String	executeAsync(String definitionId, Map<String,Object> variables)
Map<String,Object>	executeNode(String definitionId, String nodeId, Map<String,Object> variables)	执行指定节点的业务逻辑
ChainStateRepository	getChainStateRepository()
ChainDefinitionRepository	getDefinitionRepository()
EventManager	getEventManager()
List<Parameter>	getNodeParameters(String definitionId, String nodeId)	获取指定节点的参数列表
NodeStateRepository	getNodeStateRepository()
TriggerScheduler	getTriggerScheduler()
void	removeErrorListener(ChainErrorListener listener)
void	removeEventListener(ChainEventListener listener)
void	removeEventListener(Class<? extends Event> eventClass, ChainEventListener listener)
void	removeNodeErrorListener(NodeErrorListener listener)
void	resumeAsync(String stateInstanceId)
void	resumeAsync(String stateInstanceId, Map<String,Object> variables)

从类继承的方法 java.lang.Object

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

字段详细资料

definitionRepository

private final ChainDefinitionRepository definitionRepository

chainStateRepository

private final ChainStateRepository chainStateRepository

nodeStateRepository

private final NodeStateRepository nodeStateRepository

triggerScheduler

private final TriggerScheduler triggerScheduler

eventManager

private final EventManager eventManager

构造器详细资料

ChainExecutor

public ChainExecutor(ChainDefinitionRepository definitionRepository,
 ChainStateRepository chainStateRepository,
 NodeStateRepository nodeStateRepository)

ChainExecutor

public ChainExecutor(ChainDefinitionRepository definitionRepository,
 ChainStateRepository chainStateRepository,
 NodeStateRepository nodeStateRepository,
 TriggerScheduler triggerScheduler)

方法详细资料

execute

public Map<String,Object> execute(String definitionId,
 Map<String,Object> variables)

execute

public Map<String,Object> execute(String definitionId,
 Map<String,Object> variables,
 long timeout,
 TimeUnit unit)

clearDefaultStates

public void clearDefaultStates(Map<String,Object> result)

清理默认状态

参数:

result - 执行结果

executeAsync

public String executeAsync(String definitionId,
 Map<String,Object> variables)

executeNode

public Map<String,Object> executeNode(String definitionId,
 String nodeId,
 Map<String,Object> variables)

执行指定节点的业务逻辑

参数:

definitionId - 流程定义ID，用于标识哪个流程定义

nodeId - 节点ID，用于标识要执行的具体节点

variables - 执行上下文变量集合，包含节点执行所需的参数和数据

返回:

执行结果映射表，包含节点执行后的输出数据

getNodeParameters

public List<Parameter> getNodeParameters(String definitionId,
 String nodeId)

获取指定节点的参数列表

参数:

definitionId - 链定义ID，用于定位具体的链定义

nodeId - 节点ID，用于在链定义中定位具体节点

返回:

返回指定节点的参数列表

resumeAsync

public void resumeAsync(String stateInstanceId)

resumeAsync

public void resumeAsync(String stateInstanceId,
 Map<String,Object> variables)

createChain

private Chain createChain(String definitionId)

accept

private void accept(Trigger trigger,
 ExecutorService worker)

addEventListener

public void addEventListener(Class<? extends Event> eventClass,
 ChainEventListener listener)

addEventListener

public void addEventListener(ChainEventListener listener)

removeEventListener

public void removeEventListener(ChainEventListener listener)

removeEventListener

public void removeEventListener(Class<? extends Event> eventClass,
 ChainEventListener listener)

addErrorListener

public void addErrorListener(ChainErrorListener listener)

removeErrorListener

public void removeErrorListener(ChainErrorListener listener)

addNodeErrorListener

public void addNodeErrorListener(NodeErrorListener listener)

removeNodeErrorListener

public void removeNodeErrorListener(NodeErrorListener listener)

addOutputListener

public void addOutputListener(ChainOutputListener outputListener)

getDefinitionRepository

public ChainDefinitionRepository getDefinitionRepository()

getChainStateRepository

public ChainStateRepository getChainStateRepository()

getNodeStateRepository

public NodeStateRepository getNodeStateRepository()

getTriggerScheduler

public TriggerScheduler getTriggerScheduler()

getEventManager

public EventManager getEventManager()