程序包 dev.tinyflow.core.chain

类 Chain

java.lang.Object

dev.tinyflow.core.chain.Chain

public class Chain
extends Object

字段概要

字段

修饰符和类型	字段	说明
protected ChainStateRepository	chainStateRepository
protected final ChainDefinition	definition
protected EventManager	eventManager
private static final ThreadLocal<Chain>	EXECUTION_THREAD_LOCAL
private static final org.slf4j.Logger	log
protected NodeStateRepository	nodeStateRepository
protected String	stateInstanceId
protected TriggerScheduler	triggerScheduler

构造器概要

构造器

构造器	说明
Chain(ChainDefinition definition, String stateInstanceId)

方法概要

修饰符和类型	方法	说明
private long	calculateNextRetryDelay(int attempt, long maxDelayMs)	Calculates the next retry delay using exponential backoff with jitter.
static Chain	currentChain()
void	executeNode(Node node, Trigger trigger)
<T> T	executeWithLock(String instanceId, long timeout, TimeUnit unit, Supplier<T> action)
ChainStateRepository	getChainStateRepository()
ChainDefinition	getDefinition()
EventManager	getEventManager()
NodeState	getNodeState(String nodeId)
NodeState	getNodeState(String stateInstanceId, String nodeId)
NodeStateRepository	getNodeStateRepository()
ChainState	getState()
ChainState	getState(String stateInstanceId)
String	getStateInstanceId()
TriggerScheduler	getTriggerScheduler()
private ChainStatus	handleNodeError(String nodeId, Throwable throwable)
private void	handleNodeResult(Node node, Map<String,Object> prevNodeResult, String triggerEdgeId, Throwable error)
private boolean	isSameParent(Node node, Node next)	判断两个节点是否具有相同的父节点
void	notifyEvent(Event event)
void	output(Node node, Object response)
void	resume()
void	resume(Map<String,Object> variables)
private void	scheduleNextForNode(Node node, Map<String,Object> result, String byEdigeId)	为指定节点调度下一次执行
void	scheduleNode(Node node, String edgeId, TriggerType type, long delayMs)
private void	scheduleOutwardNodes(Node node, Map<String,Object> result)
void	setChainStateRepository(ChainStateRepository chainStateRepository)
void	setEventManager(EventManager eventManager)
void	setNodeStateRepository(NodeStateRepository nodeStateRepository)
void	setStateInstanceId(String stateInstanceId)
void	setStatusAndNotifyEvent(ChainStatus status)
void	setStatusAndNotifyEvent(String stateInstanceId, ChainStatus status)
void	setTriggerScheduler(TriggerScheduler triggerScheduler)
private boolean	shouldSkipNode(Node node, String edgeId)
private void	sleepUninterruptibly(long millis)	Sleeps for the specified duration, silently ignoring interrupts but preserving the interrupt status.
void	start(Map<String,Object> variables)
void	suspend()
void	suspend(Node node)
NodeState	updateNodeStateSafely(String nodeId, NodeStateModifier modifier)
NodeState	updateNodeStateSafely(String stateInstanceId, String nodeId, NodeStateModifier modifier)
ChainState	updateStateSafely(ChainStateModifier modifier)	Safely updates the chain state with optimistic locking and retry-on-conflict.
ChainState	updateStateSafely(String stateInstanceId, ChainStateModifier modifier)

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

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

字段详细资料

log

private static final org.slf4j.Logger log

EXECUTION_THREAD_LOCAL

private static final ThreadLocal<Chain> EXECUTION_THREAD_LOCAL

definition

protected final ChainDefinition definition

stateInstanceId

protected String stateInstanceId

chainStateRepository

protected ChainStateRepository chainStateRepository

nodeStateRepository

protected NodeStateRepository nodeStateRepository

eventManager

protected EventManager eventManager

triggerScheduler

protected TriggerScheduler triggerScheduler

构造器详细资料

Chain

public Chain(ChainDefinition definition,
 String stateInstanceId)

方法详细资料

currentChain

public static Chain currentChain()

notifyEvent

public void notifyEvent(Event event)

setStatusAndNotifyEvent

public void setStatusAndNotifyEvent(ChainStatus status)

setStatusAndNotifyEvent

public void setStatusAndNotifyEvent(String stateInstanceId,
 ChainStatus status)

updateStateSafely

public ChainState updateStateSafely(ChainStateModifier modifier)

Safely updates the chain state with optimistic locking and retry-on-conflict.

参数:

modifier - the modifier that applies changes and declares updated fields

抛出:

ChainUpdateTimeoutException - if update cannot succeed within timeout

updateStateSafely

public ChainState updateStateSafely(String stateInstanceId,
 ChainStateModifier modifier)

updateNodeStateSafely

public NodeState updateNodeStateSafely(String nodeId,
 NodeStateModifier modifier)

updateNodeStateSafely

public NodeState updateNodeStateSafely(String stateInstanceId,
 String nodeId,
 NodeStateModifier modifier)

calculateNextRetryDelay

private long calculateNextRetryDelay(int attempt,
 long maxDelayMs)

Calculates the next retry delay using exponential backoff with jitter.

参数:

attempt - the current retry attempt (1-based)

maxDelayMs - the maximum delay in milliseconds

返回:

the delay in milliseconds to wait before next retry

sleepUninterruptibly

private void sleepUninterruptibly(long millis)

Sleeps for the specified duration, silently ignoring interrupts but preserving the interrupt status.

参数:

millis - the length of time to sleep in milliseconds

start

public void start(Map<String,Object> variables)

executeNode

public void executeNode(Node node,
 Trigger trigger)

getNodeState

public NodeState getNodeState(String nodeId)

getNodeState

public NodeState getNodeState(String stateInstanceId,
 String nodeId)

executeWithLock

public <T> T executeWithLock(String instanceId,
 long timeout,
 TimeUnit unit,
 Supplier<T> action)

shouldSkipNode

private boolean shouldSkipNode(Node node,
 String edgeId)

handleNodeResult

private void handleNodeResult(Node node,
 Map<String,Object> prevNodeResult,
 String triggerEdgeId,
 Throwable error)

scheduleNextForNode

private void scheduleNextForNode(Node node,
 Map<String,Object> result,
 String byEdigeId)

为指定节点调度下一次执行

参数:

node - 要调度的节点

result - 节点执行结果

byEdigeId - 触发边的ID

scheduleOutwardNodes

private void scheduleOutwardNodes(Node node,
 Map<String,Object> result)

isSameParent

private boolean isSameParent(Node node,
 Node next)

判断两个节点是否具有相同的父节点

参数:

node - 第一个节点

next - 第二个节点

返回:

如果两个节点的父节点ID相同则返回true，否则返回false

scheduleNode

public void scheduleNode(Node node,
 String edgeId,
 TriggerType type,
 long delayMs)

handleNodeError

private ChainStatus handleNodeError(String nodeId,
 Throwable throwable)

suspend

public void suspend()

suspend

public void suspend(Node node)

resume

public void resume(Map<String,Object> variables)

resume

public void resume()

output

public void output(Node node,
 Object response)

getEventManager

public EventManager getEventManager()

setEventManager

public void setEventManager(EventManager eventManager)

getChainStateRepository

public ChainStateRepository getChainStateRepository()

setChainStateRepository

public void setChainStateRepository(ChainStateRepository chainStateRepository)

getDefinition

public ChainDefinition getDefinition()

getTriggerScheduler

public TriggerScheduler getTriggerScheduler()

setTriggerScheduler

public void setTriggerScheduler(TriggerScheduler triggerScheduler)

getNodeStateRepository

public NodeStateRepository getNodeStateRepository()

setNodeStateRepository

public void setNodeStateRepository(NodeStateRepository nodeStateRepository)

getStateInstanceId

public String getStateInstanceId()

getState

public ChainState getState()

getState

public ChainState getState(String stateInstanceId)

setStateInstanceId

public void setStateInstanceId(String stateInstanceId)