From 414c2fc6c3380a451ae3527da831f887dacbb789 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9F=A9=E5=8D=8E=E9=94=8B?= <799954772@qq.com> Date: Fri, 3 Nov 2023 11:28:59 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91THEN=5FSTART,THEN=5FEND?= =?UTF-8?q?=E5=91=BD=E5=90=8D=E9=94=99=E8=AF=AF=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../liteflow/flow/element/condition/WhenCondition.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/condition/WhenCondition.java b/liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/condition/WhenCondition.java index 3736be2d7..9312ea709 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/condition/WhenCondition.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/condition/WhenCondition.java @@ -69,14 +69,14 @@ public class WhenCondition extends Condition { // 这块涉及到挺多的多线程逻辑,所以注释比较详细,看到这里的童鞋可以仔细阅读 private void executeAsyncCondition(Integer slotIndex) throws Exception { Slot slot = DataBus.getSlot(slotIndex); - slot.addStep(new CmpStep("-1", "-1", CmpStepTypeEnum.THEN_START)); + slot.addStep(new CmpStep("-1", "-1", CmpStepTypeEnum.WHEN_START)); // 获取并发执行策略 ParallelStrategyExecutor parallelStrategyExecutor = ParallelStrategyHelper.loadInstance().buildParallelExecutor(this.getParallelStrategy()); // 执行并发逻辑 parallelStrategyExecutor.execute(this, slotIndex); - slot.addStep(new CmpStep("-1", "-1", CmpStepTypeEnum.THEN_END)); + slot.addStep(new CmpStep("-1", "-1", CmpStepTypeEnum.WHEN_END)); } public boolean isIgnoreError() {