From bfdb3215457053cc629377ebf2378e8cca9f215e Mon Sep 17 00:00:00 2001 From: "everywhere.z" Date: Tue, 11 Feb 2025 21:28:24 +0800 Subject: [PATCH] =?UTF-8?q?feature=20#IBCLUJ=20Step=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E5=B1=95=E7=A4=BA=E6=94=B9=E9=80=A0=20&&=20=E7=BA=BF=E7=A8=8B?= =?UTF-8?q?=E4=BF=A1=E6=81=AF=E7=9A=84=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/yomahub/liteflow/core/NodeComponent.java | 1 + .../com/yomahub/liteflow/flow/entity/CmpStep.java | 11 +++++++++++ 2 files changed, 12 insertions(+) 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; + } }