From 7cbad31ebabb984e4ee1d1bf34a9c4c897e266f4 Mon Sep 17 00:00:00 2001
From: xueqingkun <xueqingkun@126.com>
Date: Thu, 29 Aug 2024 17:48:34 +0800
Subject: [PATCH] =?UTF-8?q?1.=20=E8=B0=83=E6=95=B4=E7=BA=BF=E7=A8=8B?=
 =?UTF-8?q?=E9=98=9F=E5=88=97=E5=8F=82=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../police/service/impl/NoteRecordSplitServiceImpl.java        | 3 ---
 .../com/supervision/thread/RecordSplitClassifyThreadPool.java  | 2 +-
 .../java/com/supervision/thread/TripleExtractTaskPool.java     | 2 +-
 3 files changed, 2 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/supervision/police/service/impl/NoteRecordSplitServiceImpl.java b/src/main/java/com/supervision/police/service/impl/NoteRecordSplitServiceImpl.java
index 82dc702..1b87be3 100644
--- a/src/main/java/com/supervision/police/service/impl/NoteRecordSplitServiceImpl.java
+++ b/src/main/java/com/supervision/police/service/impl/NoteRecordSplitServiceImpl.java
@@ -73,8 +73,6 @@ public class NoteRecordSplitServiceImpl extends ServiceImpl<NoteRecordSplitMappe
 
     private final ComDictionaryService comDictionaryService;
 
-    private final CasePersonService casePersonService;
-
 
     @Override
     @Transactional(transactionManager = "dataSourceTransactionManager", rollbackFor = Exception.class)
@@ -178,7 +176,6 @@ public class NoteRecordSplitServiceImpl extends ServiceImpl<NoteRecordSplitMappe
         caseTaskRecordService.updateById(caseTaskRecord);
         return true;
 
-
     }
 
 
diff --git a/src/main/java/com/supervision/thread/RecordSplitClassifyThreadPool.java b/src/main/java/com/supervision/thread/RecordSplitClassifyThreadPool.java
index 93b198c..2826134 100644
--- a/src/main/java/com/supervision/thread/RecordSplitClassifyThreadPool.java
+++ b/src/main/java/com/supervision/thread/RecordSplitClassifyThreadPool.java
@@ -22,6 +22,6 @@ public class RecordSplitClassifyThreadPool {
     @PostConstruct
     public void init() {
         log.info("recordSplitClassify线程池初始化。线程数：{}", core);
-        executorService = ThreadUtil.newFixedExecutor(core, Integer.MAX_VALUE, "recordSplitType", false);
+        executorService = ThreadUtil.newFixedExecutor(core, 4096, "recordSplitType", false);
     }
 }
diff --git a/src/main/java/com/supervision/thread/TripleExtractTaskPool.java b/src/main/java/com/supervision/thread/TripleExtractTaskPool.java
index e7b1978..14c26ad 100644
--- a/src/main/java/com/supervision/thread/TripleExtractTaskPool.java
+++ b/src/main/java/com/supervision/thread/TripleExtractTaskPool.java
@@ -19,6 +19,6 @@ public class TripleExtractTaskPool {
     @PostConstruct
     public void init() {
         log.info("tripleExtract线程池初始化。线程数：{}", core);
-        executor = ThreadUtil.newFixedExecutor(core, Integer.MAX_VALUE, "tripleExtract", false);
+        executor = ThreadUtil.newFixedExecutor(core, 4096, "tripleExtract", false);
     }
 }