diff --git a/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/gb28181/register/RegisterService.java b/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/gb28181/register/RegisterService.java index 6b21409..e8a30e7 100644 --- a/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/gb28181/register/RegisterService.java +++ b/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/gb28181/register/RegisterService.java @@ -52,11 +52,13 @@ public class RegisterService { List enabledDevice = deviceService.getAllEnabledDevice(); - List>[]> completableFutures = ListUtil.split(enabledDevice, 10).stream().map(items -> { - CompletableFuture>[] array = enabledDevice.stream().map(this::register).toArray(CompletableFuture[]::new); + List>[]> completableFutures = new ArrayList<>(); + for (List mockingDevices : ListUtil.split(enabledDevice, 200)) { + CompletableFuture>[] array = mockingDevices.stream().map(this::register).toArray(CompletableFuture[]::new); CompletableFuture.allOf(array); - return array; - }).toList(); + Thread.sleep(500); + completableFutures.add(array); + } List>> reduce = completableFutures.stream().map(item -> Arrays.stream(item).toList()) .reduce(new ArrayList<>(), (prev, cur) -> {