在具有完全未来的循环中从db获取结果

Question

我使用的是SpringBoot和SpringDataJPA，我有一个逻辑，它由3个数据库请求组成，我想并行运行。我想在将来用于此目的。

最后，我需要从5 db查询运行的结果中构建响应对象。

所以我创造了完全未来

CompletableFuture<Long> totalFuture = CompletableFuture.supplyAsync(() ->  myRepository.getTotal());

CompletableFuture<Long> countFuture = CompletableFuture.supplyAsync(() ->  myRepository.getCount());

那我打算用。与这个未来无关。但我对循环调用有问题。如何重写它以在每个请求中使用callable，我需要从请求中传递值，然后按键排序到map中？

Map<String, Integer> groupcount = new HashMap<>();
    request.ids().forEach((key, value) -> count.put(key, myRepository
            .getGroupCountId(value));

Answer 1

为了更全面地解释，我发布了一个代码片段，我想链接它，但现在它是这样工作的。

List<CompletableFuture<Void>> completableFutures = new ArrayList<>();
Map<String, Integer> groupcount = new ConcurrentHashMap<>();
        for (var id : request.Ids().entrySet()) {
            completableFutures.add(
                CompletableFuture.runAsync(someOperation, EXECUTOR_SERVICE)
                    .thenApply(v -> runQuery(v.getValues))
                    .thenAcceptAsync(res-> groupcount .put(v.key, res));
        }
CompletableFuture.allOf(completableFutures.toArray(new CompletableFuture[0])).get();