我试图在某些数据库异常上使用重试策略实现数据库查询.重试策略的代码不是很相关,所以我没有包含它.正如您在下面的代码中看到的那样 – 我编写了一个retryCallable,它采用重试策略和populateData()中的Callable.
在getDataFromDB中,我从DB获取数据并将数据放在全局散列图中,该散列图充当应用程序级别的缓存.
此代码按预期工作.我想从另一个类调用populateData.但是,这将是一个阻止呼叫.由于这是数据库并且具有重试策略,因此这可能很慢.我想异步调用populateData.
我如何使用CompletableFuture或FutureTask来实现这一目标？
CompletableFuture.runAsync期望可运行. CompletableFuture.supplyAsync期望供应商.我以前没有实现过这些东西.所以关于最佳实践的任何建议都会有所帮助.
Class TestCallableRetry {
public void populateData() {
final Callable最佳答案
如果将populateData方法拆分为两个部分,一个是获取数据的供应商,另一个是存储它的消费者,则可以很容易地将它们与CompletableFuture链接起来.
原文链接：https://www.f2er.com/java/437484.html// Signature compatible with SupplierFailed",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版本,您的任务将在公共池中运行;适用于短期运行任务,但不适用于阻止的任务.
