java – CompletableFuture：异步调用void函数

我试图在某些数据库异常上使用重试策略实现数据库查询.重试策略的代码不是很相关,所以我没有包含它.正如您在下面的代码中看到的那样 – 我编写了一个retryCallable,它采用重试策略和populateData()中的Callable.

在getDataFromDB中,我从DB获取数据并将数据放在全局散列图中,该散列图充当应用程序级别的缓存.

此代码按预期工作.我想从另一个类调用populateData.但是,这将是一个阻止呼叫.由于这是数据库并且具有重试策略,因此这可能很慢.我想异步调用populateData.

我如何使用CompletableFuture或FutureTask来实现这一目标？
CompletableFuture.runAsync期望可运行. CompletableFuture.supplyAsync期望供应商.我以前没有实现过这些东西.所以关于最佳实践的任何建议都会有所帮助.

Class TestCallableRetry {

public void populateData() {
        final CallableretryingCallable<>(retryStrategyToRetryOnDBException(),getDataFromDB());
        Set


最佳答案
如果将populateData方法拆分为两个部分,一个是获取数据的供应商,另一个是存储它的消费者,则可以很容易地将它们与CompletableFuture链接起来.

// Signature compatible with supplierretryingCallableretryingCallable<>(retryStrategyToRetryOnDBException(),getDataFromDB());
    try {
        return retryCallable.call();
    } catch (Exception e) {
        log.error("Call to database Failed",e);
        return Collections.emptySet();
    }
}

// Signature compatible with Consumer

然后,在populateData()中：

private ExecutorService executor = Executors.newCachedThreadPool();

public void populateData() {
    CompletableFuture
        .supplyAsync(this::fetchDataWithRetry,executor)
        .thenAccept(this::storeData);
}

使用Executor的supplyAsync版本是可选的.如果您使用单个arg版本,您的任务将在公共池中运行;适用于短期运行任务,但不适用于阻止的任务.

callable

java – CompletableFuture：异步调用void函数

相关文章