From ee814890ca6c5230caf5d4f70053bed2c643fdbd Mon Sep 17 00:00:00 2001 From: gaoshuguang Date: Fri, 1 Nov 2024 11:20:22 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E9=85=8D=E7=BD=AEminFeeThrea?= =?UTF-8?q?dSize=EF=BC=8C=E5=8F=AF=E5=8A=A8=E6=80=81=E8=AE=BE=E7=BD=AE?= =?UTF-8?q?=E7=94=9F=E6=88=90=E6=9C=80=E5=B0=8F=E8=B4=B9=E9=A2=9D=E6=96=87?= =?UTF-8?q?=E4=BB=B6=E7=9A=84=E7=BA=BF=E7=A8=8B=E6=95=B0=E9=87=8F=EF=BC=8C?= =?UTF-8?q?=E4=B8=8D=E8=AE=BE=E7=BD=AE=E9=BB=98=E8=AE=A4=E4=B8=BA2?= =?UTF-8?q?=E4=B8=AA=E7=BA=BF=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/nm/gsgl/service/impl/MinFeeServiceImpl.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) 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(() -> {