public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 12:12:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化NodeComponent开始时的打印日志的时机

Browse Source
This commit is contained in:
everywhere.z
2024-12-20 12:12:05 +08:00
parent c31a63e254
commit 26c05e2ff4
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
liteflow-benchmark/liteflow-benchmark-common/src/test/resources/flow.xml
View File

@@ -30,4 +30,8 @@
<chain name="chain2"> <chain name="chain2">
THEN(a,b,s1); THEN(a,b,s1);
</chain> </chain>
<chain name="chain3">
ITERATOR(d).parallel(true).DO(THEN(a,b,c));
</chain>
</flow> </flow>

2
liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/Node.java
View File

@@ -180,8 +180,6 @@ public class Node implements Executable, Cloneable, Rollbackable{
// 判断是否可执行，所以isAccess经常作为一个组件进入的实际判断要素，用作检查slot里的参数的完备性 // 判断是否可执行，所以isAccess经常作为一个组件进入的实际判断要素，用作检查slot里的参数的完备性
if (getAccessResult() || instance.isAccess()) { if (getAccessResult() || instance.isAccess()) {
LOG.info("[O]start component[{}] execution", instance.getDisplayName());
// 这里开始进行重试的逻辑和主逻辑的运行 // 这里开始进行重试的逻辑和主逻辑的运行
NodeExecutor nodeExecutor = NodeExecutorHelper.loadInstance() NodeExecutor nodeExecutor = NodeExecutorHelper.loadInstance()
.buildNodeExecutor(instance.getNodeExecutorClass()); .buildNodeExecutor(instance.getNodeExecutorClass());