From 2f8973fd1537c5274a48bc4a4adb8857905b240d 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 12:29:03 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=E4=BF=AE=E5=A4=8D?=
 =?UTF-8?q?=E8=B6=85=E6=97=B6=E5=AF=BC=E8=87=B4=E7=9A=84=E6=8B=AC=E5=8F=B7?=
 =?UTF-8?q?=E6=B2=A1=E6=9C=89=E7=BB=93=E5=B0=BE=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../flow/element/condition/WhenCondition.java         | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 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 9312ea709..e38dbac83 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
@@ -72,11 +72,12 @@ public class WhenCondition extends Condition {
 		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.WHEN_END));
+		try {
+			// 执行并发逻辑
+			parallelStrategyExecutor.execute(this, slotIndex);
+		} finally {
+			slot.addStep(new CmpStep("-1", "-1", CmpStepTypeEnum.WHEN_END));
+		}
 	}
 
 	public boolean isIgnoreError() {