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

enhancement #I8MXIB WHEN线程池可能存在第一次调用的时候初始化

Browse Source
This commit is contained in:
everywhere.z
2024-01-12 11:06:10 +08:00
parent d5585e889a
commit c8d0dc5614
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
liteflow-core/src/main/java/com/yomahub/liteflow/builder/el/operator/WhenOperator.java
View File

@@ -4,6 +4,8 @@ import com.yomahub.liteflow.builder.el.operator.base.BaseOperator;
import com.yomahub.liteflow.builder.el.operator.base.OperatorHelper; import com.yomahub.liteflow.builder.el.operator.base.OperatorHelper;
import com.yomahub.liteflow.flow.element.Executable; import com.yomahub.liteflow.flow.element.Executable;
import com.yomahub.liteflow.flow.element.condition.WhenCondition; import com.yomahub.liteflow.flow.element.condition.WhenCondition;
import com.yomahub.liteflow.property.LiteflowConfig;
import com.yomahub.liteflow.property.LiteflowConfigGetter;
/** /**
* EL规则中的WHEN的操作符 * EL规则中的WHEN的操作符
@@ -18,9 +20,12 @@ public class WhenOperator extends BaseOperator<WhenCondition> {
OperatorHelper.checkObjectSizeGtZero(objects); OperatorHelper.checkObjectSizeGtZero(objects);
WhenCondition whenCondition = new WhenCondition(); WhenCondition whenCondition = new WhenCondition();
LiteflowConfig liteflowConfig = LiteflowConfigGetter.get();
for (Object obj : objects) { for (Object obj : objects) {
OperatorHelper.checkObjMustBeCommonTypeItem(obj); OperatorHelper.checkObjMustBeCommonTypeItem(obj);
whenCondition.addExecutable(OperatorHelper.convert(obj, Executable.class)); whenCondition.addExecutable(OperatorHelper.convert(obj, Executable.class));
whenCondition.setThreadExecutorClass(liteflowConfig.getThreadExecutorClass());
} }
return whenCondition; return whenCondition;
} }