1. 调整线程队列参数

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;
 
-
     }
 
 

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

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