panbaolin/SourceTermAnalysisSystem_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:1.优化数据同步线程池

Browse Source
This commit is contained in:
panbaolin 2026-05-28 18:54:57 +08:00
parent 7d2846af18
commit 87e51675a3
2 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
jeecg-boot-base-core/src/main/java/org/jeecg/common/properties/DataSyncProperties.java
View File

@ -12,10 +12,6 @@ import org.springframework.stereotype.Component;
@ConfigurationProperties(prefix = "data-sync") @ConfigurationProperties(prefix = "data-sync")
public class DataSyncProperties { public class DataSyncProperties {
/**
* 最小间隔（分钟）
*/
private Integer minMinute;
/** /**
* 同时最大执行数据表数量 * 同时最大执行数据表数量
*/ */

7
jeecg-module-sync/src/main/java/org/jeecg/taskConfig/job/SyncDataJob.java
View File

@ -147,12 +147,14 @@ public class SyncDataJob implements Job {
pstmt.setString(2, syncStrategy.getTableName().toUpperCase()); pstmt.setString(2, syncStrategy.getTableName().toUpperCase());
pstmt.setString(3, syncStrategy.getColumnName().toUpperCase()); pstmt.setString(3, syncStrategy.getColumnName().toUpperCase());
ResultSet rs = pstmt.executeQuery(); try(ResultSet rs = pstmt.executeQuery()){
if (rs.next()) { if (rs.next()) {
String dataType = rs.getString("data_type").toUpperCase(); String dataType = rs.getString("data_type").toUpperCase();
return dataType.contains("DATE") || dataType.contains("TIME"); return dataType.contains("DATE") || dataType.contains("TIME");
} }
} }
}
return false; return false;
} }
@ -205,8 +207,7 @@ public class SyncDataJob implements Job {
int maximumPoolSize = Runtime.getRuntime().availableProcessors(); int maximumPoolSize = Runtime.getRuntime().availableProcessors();
int maxExecSize = Math.min(dataSyncProperties.getMaxExecNum(), maximumPoolSize); int maxExecSize = Math.min(dataSyncProperties.getMaxExecNum(), maximumPoolSize);
String threadNamePrefix = "data_sync"; String threadNamePrefix = "data_sync";
int queueCapacity = maxExecSize * 2;
CustomThreadFactory threadFactory = new CustomThreadFactory(threadNamePrefix); CustomThreadFactory threadFactory = new CustomThreadFactory(threadNamePrefix);
threadPoolExecutor = new ThreadPoolExecutor(maxExecSize,maximumPoolSize,5, TimeUnit.SECONDS,new LinkedBlockingQueue<>(queueCapacity),threadFactory); threadPoolExecutor = new ThreadPoolExecutor(maxExecSize,(maxExecSize*2),maxExecSize, TimeUnit.SECONDS,new LinkedBlockingQueue<>(),threadFactory);
} }
} }