KingChan
/
liteFlow
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

【fix】THEN_START,THEN_END命名错误的问题

This commit is contained in:
韩华锋 2023-11-03 11:28:59 +08:00
parent ae97426ef3
commit 414c2fc6c3
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/condition/WhenCondition.java
View File

@ -69,14 +69,14 @@ public class WhenCondition extends Condition {
// 这块涉及到挺多的多线程逻辑，所以注释比较详细，看到这里的童鞋可以仔细阅读 // 这块涉及到挺多的多线程逻辑，所以注释比较详细，看到这里的童鞋可以仔细阅读
private void executeAsyncCondition(Integer slotIndex) throws Exception { private void executeAsyncCondition(Integer slotIndex) throws Exception {
Slot slot = DataBus.getSlot(slotIndex); 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 parallelStrategyExecutor = ParallelStrategyHelper.loadInstance().buildParallelExecutor(this.getParallelStrategy());
// 执行并发逻辑 // 执行并发逻辑
parallelStrategyExecutor.execute(this, slotIndex); 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() { public boolean isIgnoreError() {