From 7a666e2bdbbbf948b4a41882826bb889a9afe609 Mon Sep 17 00:00:00 2001 From: tianliyong Date: Wed, 28 Dec 2022 16:04:35 +0800 Subject: [PATCH] =?UTF-8?q?=E8=8E=B7=E5=8F=96fileKey=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E4=BC=98=E5=8C=96=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/cn/axzo/oss/service/impl/FileServiceImpl.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/oss-service/src/main/java/cn/axzo/oss/service/impl/FileServiceImpl.java b/oss-service/src/main/java/cn/axzo/oss/service/impl/FileServiceImpl.java index d35afbd..0492d54 100644 --- a/oss-service/src/main/java/cn/axzo/oss/service/impl/FileServiceImpl.java +++ b/oss-service/src/main/java/cn/axzo/oss/service/impl/FileServiceImpl.java @@ -357,10 +357,11 @@ public class FileServiceImpl implements FileService { private void asyncSaveFile(List resList) { List> completableFutures = new ArrayList<>(resList.size() / 10 + 1); - Lists.partition(resList, 10) - .forEach(findFileKeyResponses -> completableFutures.add(CompletableFuture.runAsync( - () -> findFileKeyResponses.forEach(response -> saveFile(response)) + Lists.partition(resList, 10).forEach(findFileKeyResponses -> + completableFutures.add(CompletableFuture.runAsync(() -> + findFileKeyResponses.forEach(response -> saveFile(response)) ))); + CompletableFuture.allOf(completableFutures.toArray(new CompletableFuture[0])).join(); } private File saveFile(FindFileKeyResponse response) {