1异步数据入库修线程数量修改为按照核心来

amos-boot-system-tzs/amos-boot-module-tzspatrol/amos-boot-module-tzspatrol-biz/src/main/java/com/yeejoin/amos/patrol/business/listener/CheckRecordInsertListener.java

@@ -30,6 +30,8 @@ public class CheckRecordInsertListener implements ApplicationContextAware, Appli
     @Autowired
     Executor asyncServiceExecutor;
 
+    private int curSystemThreads = Runtime.getRuntime().availableProcessors();
+
 
     @Override
     public void onApplicationEvent(CheckRecordInsertEvent event) {
@@ -39,7 +41,7 @@ public class CheckRecordInsertListener implements ApplicationContextAware, Appli
     @PostConstruct
     public void init() {
         CheckRecordDataConsumer consumer = new CheckRecordDataConsumer(blockingQueue, applicationContext);
-        for (int i = 0; i < 10; i++) {
+        for (int i = 0; i < curSystemThreads; i++) {
             asyncServiceExecutor.execute(consumer);
         }
     }