我的数据库方法返回一个CompletableFuture来异步处理数据库，然后在主线程上处理结果。accountEntity);}@Override
public CompletableFuture<Op
浏览 3提问于2022-10-08得票数 0
回答已采纳
我需要向第三方urls发送请求，所以我在getStatus()方法上使用了@Async，该方法返回enum的CompletableFuture，如果抛出TimeoutException，我想考虑状态为DOWN或如何捕获每个调用的InterruptedException和ExecutionException firstAppStatus = service1.getStatus().get{
firstAppStatus = Component
浏览 140提问于2020-07-29得票数 0
回答已采纳
如果我有像下面这样的异步方法， /* Step #1: Do some sync prep work */}
如果步骤1中的代码抛出，get()的调用者将在获得它返回的CompletableFuture之前得到异常，而如果步骤2中返回的</
浏览 4提问于2018-08-17得票数 1
我有大约5项与从HTTP获取数据以及基于数据处理和生成结果有关的任务。有什么更好的方法可以实现吗？举个例子会有帮助。
浏览 0提问于2018-02-07得票数 2
2回答
我是CompletableFuture新手，我想调用MetadataLoginUtil::login方法，它可以引发异常。然而，下面的代码是没有编译的，尽管我已经写了“异常”。public void run() throws ConnectionException {
CompletableFuture<Void> mt = CompletableFuture.supplyAsync
浏览 6提问于2016-11-24得票数 4
回答已采纳
我刚刚开始使用CompletableFuture，并且已经很喜欢它了。现在，一旦数据到达，我的代码将应用一些处理逻辑。在异常情况下，我使用异常方法重新抛出MyCustomException.thenAp
浏览 3提问于2021-04-02得票数 1
回答已采纳
我是completableFuture的新手，我想要做的是在spring项目下面有这样的逻辑，我试图将它转换为使用completableFuture的并行处理方法。现在，我试图用上面的逻辑进行并行处理。<Optional<Obj>> optionalObjFuture = CompletableFuture.supplyAsync( () -> {//get<
浏览 10提问于2021-04-07得票数 0
我被CompletableFuture异常处理困住了处理器类当前具有此代码。如何消除用于在阶段之间共享状态的错误本地字段？).thenCompose(x -> {
浏览 0提问于2018-10-25得票数 1
回答已采纳
我正在使用CompletableFuture，并有一个关于异常处理的问题。我有这样的代码，如果任何validate()或process()方法抛出一个异常，那么它将由ExceptionHandler处理。然而，当我像这样使用CompletableFuture时，抛出的异常将被包装在CompletionException中。我可以知道如何确保在那里调用我的Excep
浏览 3提问于2019-02-13得票数 4
回答已采纳
如何将阻塞方法调用“转换”为？必须正确处理这些问题，这样completableFuture.get()就会抛出一个InterruptedException或ExecutionException。它必须是一个CompletableFuture (可能是包装的)。我尝试过这样做，但这不能正确地处理异常：
CompletableFuture.completedFuture(Void.TYPE).thenApply(v -&
浏览 2提问于2019-06-07得票数 3
我将所有这些异步调用存储在List<CompletableFuture<X>> list上。我想收集所有的结果，所以我需要等待所有这些调用完成。一种方法是创建一个CompletableFuture.allOf(list.toArray(...))...
另一种方法是使用：list.stream.map(cf -> cf.join())...我只是想知道，与直接等待单个CompletableFuture完成相比，创建全局CompletableFuture并等待
浏览 4提问于2021-10-29得票数 3
回答已采纳
我目前在Java中有一些类似于此的代码，但我想重构它。List<Object> combinedStatus = new ArrayList(); CompletableFuture<Object> future = ask(batch);}
for (CompletableFuture<Object这是我的重构版本--有人能给
浏览 3提问于2022-07-19得票数 0
回答已采纳
，我试图用Collector实现的是，我有一个类来收集一堆度量，在CompletableFuture完全完成之后，我会执行Collector来发布度量。finally是否保证它将在最后执行，因为我认为.get()应该被阻塞，直到它完成？()); String result = s.get(1000, TimeUnit.MILLISECONDS);
System.out.println<String> query(Collector co
浏览 4提问于2021-01-23得票数 3
回答已采纳
但是，testCase2不处理异常并引发错误。我是不是遗漏了什么？抱歉，如果是的话，我对这件事很陌生。@Test CompletableFuture.supplyAsync(() -> { return "Promise"; return "Fake Pr
浏览 4提问于2017-04-11得票数 1
回答已采纳
我有一个Spring启动服务，其中包含一些代码，如下面所示，用于并行异步调用：CompletableFuturefuture2 = accountManager.getResult(url2)；String result1= future1.get()；
String result2 = future2.
浏览 1提问于2020-05-28得票数 0
我对这个完整的未来概念非常陌生。我使用Spring的异步注释，为此，我为executor和异常处理程序添加了一个文件配置，如下所示：public Executor getAsyncExecutor() {AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {}}
现在，如果在上面的方法
浏览 3提问于2022-04-06得票数 0
我正试图抓住像CompletableFuture.runAsync(() -> {throw new RuntimeException();});这样的期货的不寻常情况
以下是我所做的(这不起作用)
浏览 13提问于2020-10-26得票数 2
因此，我尝试通过以下方法来等待多个期货的单一超时final CompletableFuture<String> completedFuture .get(1, TimeUnit.MILLISECONDS);this still fail
浏览 4提问于2021-10-07得票数 0
回答已采纳
使用Java 8强大的功能CompletableFuture，我想使用这个新功能的异常来转换我的旧异步代码。但选中的异常是困扰我的问题。这是我的代码。CompletableFuture<Void> asyncTaskCompletableFuture =
CompletableFuture.supplyAsync(t-> processor.pro
浏览 0提问于2016-09-06得票数 10
如何在Kotlin中为下面的方法签名实现函数。我面临的问题是如何使语法正确。public CompletableFuture<T> whenCompleteAsync(
BiConsumer<? super T, ?
浏览 11提问于2022-12-04得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
