Sheldan/abstracto
1
0
Fork 0
mirror of https://github.com/Sheldan/abstracto.git synced 2026-04-16 04:21:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

[AB-25] artificial delay

Browse Source
This commit is contained in:
Sheldan
2022-11-20 23:20:07 +01:00
parent 2db36ef96b
commit a0b2fc9c31
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
abstracto-application/abstracto-modules/experience-tracking/experience-tracking-impl/src/main/java/dev/sheldan/abstracto/experience/service/AUserExperienceServiceBean.java
View File

@@ -188,9 +188,14 @@ public class AUserExperienceServiceBean implements AUserExperienceService {
List<List<Long>> partitionedUserIds = ListUtils.partition(userIds, 100); List<List<Long>> partitionedUserIds = ListUtils.partition(userIds, 100);
List<CompletableFuture<List<Member>>> memberLoadingFutures = new ArrayList<>(); List<CompletableFuture<List<Member>>> memberLoadingFutures = new ArrayList<>();
partitionedUserIds.forEach(userIdsPart -> { for (List<Long> userIdsPart : partitionedUserIds) {
memberLoadingFutures.add(memberService.getMembersInServerAsync(server.getId(), userIdsPart)); memberLoadingFutures.add(memberService.getMembersInServerAsync(server.getId(), userIdsPart));
}); try {
Thread.sleep(500L);
} catch (InterruptedException e) {
log.error("Failed to sleep.", e);
}
}
CompletableFutureList<List<Member>> listCompletableFutureList = new CompletableFutureList<>(memberLoadingFutures); CompletableFutureList<List<Member>> listCompletableFutureList = new CompletableFutureList<>(memberLoadingFutures);
listCompletableFutureList.getMainFuture().whenComplete((result, throwable) -> { listCompletableFutureList.getMainFuture().whenComplete((result, throwable) -> {
List<Member> members = new ArrayList<>(); List<Member> members = new ArrayList<>();