使用 CompletableFuture 调用存储过程

Question

我有一个 Springboot API，它使用可调用语句最多进行 6 次存储过程调用。我想让这个调用异步。是否可以使用 CompleteableFuture(java8) 来实现这一点？？？

Answer 1

数据库连接通常不是线程安全的。您计划每次通话使用一个连接吗？
如果是，以下代码将并行执行可调用语句。请注意，我使用了 vavr 库来简化异常处理。

public List<Boolean> concurrentCalls(Supplier<Connection> connectionSupplier, List<String> statements) {
        Function<String, Either<Throwable, Boolean>> executeStatement = statement ->
                Try.of(() -> connectionSupplier.get()
                .prepareCall(statement)
                .execute())
                .toEither();

        List<CompletableFuture<Boolean>> completableFutures = statements.stream()
                .map(statement ->
                        CompletableFuture.supplyAsync(() -> executeStatement.apply(statement))
                        .thenApply( Either::get) // Handle exceptions as required
                )
                .collect(Collectors.toList());

        return CompletableFuture.allOf( completableFutures.toArray( new CompletableFuture[0]))
                         .thenApply( any ->
                                 completableFutures
                                         .stream()
                                         .map(CompletableFuture::join)
                                         .collect(Collectors.toList())
                         )
                         .join();
}