From 5b487b996abd992d4827a0c8d376f3de5d5f3df3 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Thu, 1 Dec 2016 13:07:05 +0800 Subject: [PATCH] update --- .../com/lyms/platform/operate/web/facade/RiskReportFacade.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/RiskReportFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/RiskReportFacade.java index efbd7b3..dd7f863 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/RiskReportFacade.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/RiskReportFacade.java @@ -33,7 +33,7 @@ import java.util.concurrent.*; @Component public class RiskReportFacade { - + private static ExecutorService pool = Executors.newFixedThreadPool(4); @Autowired private PatientsService patientsService; @@ -109,7 +109,7 @@ public class RiskReportFacade { List riskLevelConfig = basicConfigService.queryBasicConfig(basicConfigQuery); if (CollectionUtils.isNotEmpty(riskLevelConfig)) { - ExecutorService pool = Executors.newFixedThreadPool(riskLevelConfig.size()); + for(BasicConfig levelConfig : riskLevelConfig) { if ("e637b361-99cf-41eb-84f2-f0dab596e928".equals(levelConfig.getId())) @@ -123,8 +123,7 @@ public class RiskReportFacade { Future f = pool.submit(c); futures.add(f); } - // 关闭线程池 - pool.shutdown(); + } if (CollectionUtils.isNotEmpty(futures)) -- 1.8.3.1