diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java b/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java index f4505a0aa..3b3aa7f3f 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java @@ -91,6 +91,7 @@ public abstract class NodeComponent{ cmpStep.setInstance(this); cmpStep.setRefNode(this.getRefNode()); cmpStep.setStartTime(new Date()); + cmpStep.setThreadName(Thread.currentThread().getName()); slot.addStep(cmpStep); StopWatch stopWatch = new StopWatch(); diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/flow/entity/CmpStep.java b/liteflow-core/src/main/java/com/yomahub/liteflow/flow/entity/CmpStep.java index 0ce75da12..166552073 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/flow/entity/CmpStep.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/flow/entity/CmpStep.java @@ -59,6 +59,9 @@ public class CmpStep { // 自定义步骤数据 private Object stepData; + // 运行线程名称 + private String threadName; + public CmpStep(String nodeId, String nodeName, CmpStepTypeEnum stepType) { this.nodeId = nodeId; @@ -273,4 +276,12 @@ public class CmpStep { public void setStepData(Object stepData) { this.stepData = stepData; } + + public String getThreadName() { + return threadName; + } + + public void setThreadName(String threadName) { + this.threadName = threadName; + } }