keliu-tool 上传数据时线程池ä¼流程优化

label-tool-keliu/src/main/java/com/viontech/label/tool/keliu/controller/KeliuController.java

@@ -84,6 +84,13 @@ public class KeliuController {
                     responses.add(submit);
                     responses.add(submit);
                 }
                 }
             } finally {
             } finally {
+                while (threadPoolExecutor.getActiveCount() > 0) {
+                    try {
+                        Thread.sleep(1000);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                }
                 threadPoolExecutor.shutdown();
                 threadPoolExecutor.shutdown();
                 SEND_DATA = false;
                 SEND_DATA = false;
             }
             }
@@ -92,7 +99,7 @@ public class KeliuController {
         long failed = 0;
         long failed = 0;
         for (Future<JsonMessageUtil.JsonMessage> future : responses) {
         for (Future<JsonMessageUtil.JsonMessage> future : responses) {
             try {
             try {
-                JsonMessageUtil.JsonMessage jsonMessage = future.get();
+                JsonMessageUtil.JsonMessage jsonMessage = future.get(20, TimeUnit.SECONDS);
                 if (jsonMessage == null || !jsonMessage.isSuccess()) {
                 if (jsonMessage == null || !jsonMessage.isSuccess()) {
                     failed++;
                     failed++;
                 } else {
                 } else {