wangli/oss
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

获取fileKey接口优化调整

Browse Source
This commit is contained in:
tianliyong 2022-12-28 16:04:35 +08:00
parent 84ff298710
commit 7a666e2bdb
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
oss-service/src/main/java/cn/axzo/oss/service/impl/FileServiceImpl.java
View File

@ -357,10 +357,11 @@ public class FileServiceImpl implements FileService {
private void asyncSaveFile(List<FindFileKeyResponse> resList) { private void asyncSaveFile(List<FindFileKeyResponse> resList) {
List<CompletableFuture<Void>> completableFutures = new ArrayList<>(resList.size() / 10 + 1); List<CompletableFuture<Void>> completableFutures = new ArrayList<>(resList.size() / 10 + 1);
Lists.partition(resList, 10) Lists.partition(resList, 10).forEach(findFileKeyResponses ->
.forEach(findFileKeyResponses -> completableFutures.add(CompletableFuture.runAsync( completableFutures.add(CompletableFuture.runAsync(() ->
() -> findFileKeyResponses.forEach(response -> saveFile(response)) findFileKeyResponses.forEach(response -> saveFile(response))
))); )));
CompletableFuture.allOf(completableFutures.toArray(new CompletableFuture[0])).join();
} }
private File saveFile(FindFileKeyResponse response) { private File saveFile(FindFileKeyResponse response) {