From 4a274743824f4e8303381c51cc1f847471a5b66f Mon Sep 17 00:00:00 2001
From: hanrenchun <hanrenchun>
Date: Fri, 5 Jan 2024 15:17:17 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BD=A6=E8=BE=86=E5=88=A0=E9=99=A4=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9,=E8=AE=BE=E5=A4=87=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../task/DevopeDeviceTask.java                | 26 +++++++++----------
 .../task/TMotorvehicleTask.java               |  2 +-
 .../ssf/mysqloracletest/task/TjksbglTask.java | 24 ++++++++---------
 3 files changed, 26 insertions(+), 26 deletions(-)

diff --git a/src/main/java/com/ssf/mysqloracletest/task/DevopeDeviceTask.java b/src/main/java/com/ssf/mysqloracletest/task/DevopeDeviceTask.java
index acbef5e..8ba5963 100644
--- a/src/main/java/com/ssf/mysqloracletest/task/DevopeDeviceTask.java
+++ b/src/main/java/com/ssf/mysqloracletest/task/DevopeDeviceTask.java
@@ -45,25 +45,25 @@ public class DevopeDeviceTask {
             Page<TJksbglMysql> page = new Page<>(1, 1000);
             List<TJksbglMysql> resultList = jksbglMysqlService.page(page, queryWrapper).getRecords();
 
-            CountDownLatch latch = new CountDownLatch(resultList.size());
-            ExecutorService DevicePool = Executors.newFixedThreadPool(5);
+//            CountDownLatch latch = new CountDownLatch(resultList.size());
+//            ExecutorService DevicePool = Executors.newFixedThreadPool(5);
 
             for (TJksbglMysql bean : resultList) {
-                DevicePool.submit(() -> {
+//                DevicePool.submit(() -> {
                     cleanJksbInfo(bean);
                     logger.info("清洗完成");
-                    latch.countDown();
-                });
+//                    latch.countDown();
+//                });
             }
 
-            try {
-                //Wait for all threads to complete
-                latch.await();
-            } catch (InterruptedException e) {
-                e.printStackTrace();
-            }
-            //关闭线程池
-            DevicePool.shutdown();
+//            try {
+//                //Wait for all threads to complete
+//                latch.await();
+//            } catch (InterruptedException e) {
+//                e.printStackTrace();
+//            }
+//            //关闭线程池
+//            DevicePool.shutdown();
         } catch (Exception e) {
             logger.info(StringKit.getTrace(e));
         }
diff --git a/src/main/java/com/ssf/mysqloracletest/task/TMotorvehicleTask.java b/src/main/java/com/ssf/mysqloracletest/task/TMotorvehicleTask.java
index 27c0460..3a1ec56 100644
--- a/src/main/java/com/ssf/mysqloracletest/task/TMotorvehicleTask.java
+++ b/src/main/java/com/ssf/mysqloracletest/task/TMotorvehicleTask.java
@@ -144,7 +144,7 @@ public class TMotorvehicleTask {
             LambdaQueryWrapper<TransitVehicleRecord> deleteWrapper = Wrappers.lambdaQuery();
             deleteWrapper.le(TransitVehicleRecord::getPartitionField, twoDaysAgo);
 //            int countTM = vehicleRecordService.count(deleteWrapper);
-            deleteWrapper.last("LIMIT 10000");
+            deleteWrapper.last("LIMIT 1000");
             boolean result = vehicleRecordService.remove(deleteWrapper);
 
             if (result) {
diff --git a/src/main/java/com/ssf/mysqloracletest/task/TjksbglTask.java b/src/main/java/com/ssf/mysqloracletest/task/TjksbglTask.java
index 8ef6f55..b722817 100644
--- a/src/main/java/com/ssf/mysqloracletest/task/TjksbglTask.java
+++ b/src/main/java/com/ssf/mysqloracletest/task/TjksbglTask.java
@@ -64,14 +64,14 @@ public class TjksbglTask {
                 jksbTag = true;
 
                 int count = countjksb / oncesCounts;
-                CountDownLatch latch = new CountDownLatch(count);
-                ExecutorService jksbPool = Executors.newFixedThreadPool(50);
+//                CountDownLatch latch = new CountDownLatch(count);
+//                ExecutorService jksbPool = Executors.newFixedThreadPool(50);
 
                 for (int i = 0; i <= count; i++) {
                     Map jksbMap = new HashMap();
                     jksbMap.put("rowStart", i * oncesCounts);
                     jksbMap.put("rowEnd", (i + 1) * oncesCounts);
-                    jksbPool.submit(() -> {
+//                    jksbPool.submit(() -> {
                         try {
                             List<TJksbglOracle> jksbs = jksbOracleService.getJKsbList(jksbMap);
                             for (TJksbglOracle jksb : jksbs) {
@@ -90,19 +90,19 @@ public class TjksbglTask {
                         } catch (Exception e) {
                             logger.info("jksbs:" + StringKit.getTrace(e));
                         }
-                        latch.countDown();
-                    });
+//                        latch.countDown();
+//                    });
                     logger.info("jksbMap数据总量:" + countjksb + "," + "当前处理下标:" + jksbMap.get("rowStart") + "/" + jksbMap.get("rowEnd"));
                 }
 
-                try {
-                    // Wait for all threads to complete
-                    latch.await();
-                } catch (InterruptedException e) {
-                    e.printStackTrace();
-                }
+//                try {
+//                    // Wait for all threads to complete
+//                    latch.await();
+//                } catch (InterruptedException e) {
+//                    e.printStackTrace();
+//                }
                 // 关闭线程池
-                jksbPool.shutdown();
+//                jksbPool.shutdown();
             }
 
         } catch (Exception e) {