From d8cab292de9b66544150bdb8cc1625fd0195d9c6 Mon Sep 17 00:00:00 2001 From: shikong <919411476@qq.com> Date: Mon, 11 Mar 2024 15:31:49 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=B9=E9=87=8F=E6=B3=A8=E5=86=8C=20?= =?UTF-8?q?=E6=94=B9=E4=B8=BA=E4=B8=80=E6=89=B9=20200=E4=B8=AA=20=E6=AF=8F?= =?UTF-8?q?=E6=AC=A1=E9=97=B4=E9=9A=94=20500ms=20=E9=81=BF=E5=85=8D?= =?UTF-8?q?=E9=80=9F=E5=BA=A6=E8=BF=87=E5=BF=AB=E6=8A=8A=20wvp=20=E5=8D=A1?= =?UTF-8?q?=E6=AD=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/gb28181/register/RegisterService.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) 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) -> {