From 826970357ed712aaafd3cd3167ef085ece0d2cad Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Tue, 22 Apr 2025 15:55:57 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/njcn/access/runner/AutoAccessTimer.java    | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/iot-access/access-boot/src/main/java/com/njcn/access/runner/AutoAccessTimer.java b/iot-access/access-boot/src/main/java/com/njcn/access/runner/AutoAccessTimer.java
index 2c1a305..81736ff 100644
--- a/iot-access/access-boot/src/main/java/com/njcn/access/runner/AutoAccessTimer.java
+++ b/iot-access/access-boot/src/main/java/com/njcn/access/runner/AutoAccessTimer.java
@@ -16,6 +16,7 @@ import org.springframework.boot.ApplicationRunner;
 import org.springframework.stereotype.Component;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
 import java.util.Objects;
 import java.util.concurrent.*;
@@ -55,14 +56,19 @@ public class AutoAccessTimer implements ApplicationRunner {
                 // 创建一个ExecutorService来处理这些任务
                 List<Future<Void>> futures = new ArrayList<>();
                 // 提交任务给线程池执行
-                for (int i = 0; i < 10; i++) {
-                    int index = i;
+//                for (int i = 0; i < 10; i++) {
+//                    int index = i;
+//                    futures.add(executor.submit(() -> {
+//                        accessDev(subLists.get(index));
+//                        return null;
+//                    }));
+//                }
+                for (List<CsEquipmentDeliveryPO> subList : subLists) {
                     futures.add(executor.submit(() -> {
-                        accessDev(subLists.get(index));
+                        accessDev(subList);
                         return null;
                     }));
                 }
-
                 // 等待所有任务完成
                 for (Future<Void> future : futures) {
                     try {