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))