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

Merge branch 'feature/joint_log' into 'pre'

Browse Source 
Feature/joint log

See merge request infra/oss!56
This commit is contained in:
田立勇 2022-12-28 08:07:38 +00:00
commit 164a46e04a
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) {