diff --git a/ParamDownload/src/main/java/com/nm/gsgl/service/impl/MinFeeServiceImpl.java b/ParamDownload/src/main/java/com/nm/gsgl/service/impl/MinFeeServiceImpl.java index 9d7c80ff..a8961b9e 100644 --- a/ParamDownload/src/main/java/com/nm/gsgl/service/impl/MinFeeServiceImpl.java +++ b/ParamDownload/src/main/java/com/nm/gsgl/service/impl/MinFeeServiceImpl.java @@ -78,12 +78,11 @@ public class MinFeeServiceImpl implements MinFeeService { minFtpDownloadService.getMinFeeHrMdTask(uuid); //开始查询sqlite任务表中华软未处理数据任务 List businessTasks = DatabaseUtil.selectBusines(sqliteDriverName, sqliteUrl, Constant.SELECT_BUSINESS_HANDLER_HR_MIN_FEE); - - + String minFeeThreadSize = PropertiesUtil.getValue("minFeeThreadSize"); + int minFeeThreadSizeInt = Integer.parseInt((minFeeThreadSize != null) ? minFeeThreadSize : "2"); if (businessTasks.size() > 0) { - //创建线程池 - ExecutorService executor = Executors.newFixedThreadPool(2); // 可以根据实际情况调整线程池的大小 + ExecutorService executor = Executors.newFixedThreadPool(minFeeThreadSizeInt); // 可以根据实际情况调整线程池的大小 for (BusinessTasks businessTask : businessTasks) { final String protocolType = businessTask.getProtocolType(); executor.submit(() -> {