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

修复 高并发下generate()方法报requestIdGenerator空指针问题

Browse Source
This commit is contained in:
zendwang
2022-07-12 00:38:57 +08:00
parent 380a0b38b9
commit e649b5415c
1 changed files with 8 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
liteflow-core/src/main/java/com/yomahub/liteflow/flow/id/IdGeneratorHelper.java
View File

@@ -1,6 +1,5 @@
package com.yomahub.liteflow.flow.id;
import cn.hutool.core.util.StrUtil;
import com.yomahub.liteflow.exception.RequestIdGeneratorException;
import com.yomahub.liteflow.property.LiteflowConfig;
import com.yomahub.liteflow.property.LiteflowConfigGetter;
@@ -20,7 +19,14 @@ public class IdGeneratorHelper {
private volatile static IdGeneratorHelper INSTANCE;
private IdGeneratorHelper() {
LiteflowConfig liteflowConfig = LiteflowConfigGetter.get();
String requestIdGeneratorClass = liteflowConfig.getRequestIdGeneratorClass();
try {
Class<RequestIdGenerator> idGenerateClass = (Class<RequestIdGenerator>) Class.forName(requestIdGeneratorClass);
requestIdGenerator = ContextAwareHolder.loadContextAware().registerBean(idGenerateClass);
} catch (Exception e) {
throw new RequestIdGeneratorException(e.getMessage());
}
}
public static IdGeneratorHelper getInstance() {
@@ -30,17 +36,6 @@ public class IdGeneratorHelper {
synchronized (IdGeneratorHelper.class) {
if (Objects.isNull(INSTANCE)) {
INSTANCE = new IdGeneratorHelper();
LiteflowConfig liteflowConfig = LiteflowConfigGetter.get();
String requestIdGeneratorClass = liteflowConfig.getRequestIdGeneratorClass();
if (StrUtil.isBlank(requestIdGeneratorClass)) {
requestIdGenerator = new DefaultRequestIdGenerator();
}
try {
Class<RequestIdGenerator> idGenerateClass = (Class<RequestIdGenerator>) Class.forName(requestIdGeneratorClass);
requestIdGenerator = ContextAwareHolder.loadContextAware().registerBean(idGenerateClass);
} catch (Exception e) {
throw new RequestIdGeneratorException(e.getMessage());
}
}
}
}