From d80490a83a998b88602550c43358ae2dc1a98d66 Mon Sep 17 00:00:00 2001 From: "1437892690@qq.com" <1437892690@qq.com> Date: Wed, 5 Mar 2025 18:36:39 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E8=BD=AC=E6=8D=A2=E8=8A=82=E7=82=B9=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 关联 #[1369471061557248]数据转换节点优化 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1369471061557248 --- .../java/neatlogic/framework/common/config/Config.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/main/java/neatlogic/framework/common/config/Config.java b/src/main/java/neatlogic/framework/common/config/Config.java index 4cf235041..a0e77136c 100644 --- a/src/main/java/neatlogic/framework/common/config/Config.java +++ b/src/main/java/neatlogic/framework/common/config/Config.java @@ -139,6 +139,8 @@ public class Config { private static String CHANGELOG_JDBC_SOCKETTIME;//changelog jdbc 读取数据时间耗时限制 + private static int DATACONVERSION_THREAD_MAXIMUM_SIZE;//数据转换步骤并发数，默认为1 + static { NEATLOGIC_HOME = System.getenv("NEATLOGIC_HOME"); if (StringUtils.isBlank(NEATLOGIC_HOME)) { @@ -486,6 +488,9 @@ public class Config { return CHANGELOG_JDBC_SOCKETTIME; } + public static int DATACONVERSION_THREAD_MAXIMUM_SIZE() { + return DATACONVERSION_THREAD_MAXIMUM_SIZE; + } public static Properties properties = new Properties(); private void initConfigFile() { @@ -656,6 +661,8 @@ public class Config { System.exit(1); } + DATACONVERSION_THREAD_MAXIMUM_SIZE = Integer.parseInt(prop.getProperty("dataconversion.thread.maximum.size", "1")); + //处理其他配置 Reflections reflections = new Reflections("neatlogic"); Set> listeners = reflections.getSubTypesOf(IConfigListener.class); -- Gitee