completable-future 相关问题

在Java 8中,可以显式完成的Future(设置其值和状态),并且可以包括在完成时触发的依赖函数和动作。

WebTarget Bean实例化在Spring中失败,同时通过CompletableFuture调用包含的类方法

我正在从Spring Boot应用程序调用其他Web服务。为了提高性能而不是顺序调用它们,我想将CompletableFuture.supplyAsync()实现为...

回答 1 投票 4

Comboine CompletableStage动态地传播并最终传播错误

我需要动态组合CompletionStages(基于计算结果),以便不阻止执行,最终我需要捕获在...期间可能发生的异常。]]

回答 1 投票 0

将CompletableFuture和JdbcTamplate结合起来的正确方法是什么?

我正在尝试使用JdbcTemplate对数据库进行一些简单的查询。我的方法正确吗? @Async public CompletableFuture query1(){return ...

回答 1 投票 0

CompletableFuture链未调用thenAcceptAsync

doTask()是一种方法,如果previousStepResult成功,则执行某些操作,否则记录并按原样返回previousStepResult。下面的代码可以正常工作,并且结论()也可以执行,但是仅...

回答 1 投票 0

将未来转换为单声道

我有遗留代码,它返回convert java.util.concurrent.Future,现在我应该将此方法调用包装在返回反应堆发布者Mono或Flux的层中。我相信转换的方法...

回答 1 投票 0

CompletableFuture无法像某些Java 8流代码所接受的那样工作

我正在关注此SO答案以下代码段可以正常工作。使用所有线程代码段1 scrolledPage.stream().filter(this :: isUserDoesntHaveId).map(this :: processSingle)...

回答 1 投票 0

将未来转换为单声道

我有遗留代码,它返回convert java.util.concurrent.Future,现在我应该将此方法调用包装在返回反应堆发布者Mono或Flux的层中。我相信转换的方法...

回答 1 投票 0

如何异步执行CompletableFuture

我创建了一个实现异步重试模式的方法。实际上,我希望当我调用此方法时,请求应在单独的线程中处理,并且应重试一些延迟。private&...

回答 1 投票 0

同时运行Void CompletionStage,但忽略结果

我有两个完成阶段方法调用,如果不满足条件,则每个方法调用一个远程服务。它们都是相当长时间运行的进程,我们需要减少延迟。我也不在乎...

回答 1 投票 1

在运行异步任务流时使用CompletableFuture的最佳方法是什么?

我有一个弹簧组件EventSvcFacade,它具有三个EventValidationSvc实现类实例的列表。这些类均实现方法boolean validate(T request),并采用...

回答 1 投票 1

CompleatableFuture是否可以通过句柄方法异常完成?

我正在尝试将存储库异常映射到服务异常。这样的方法好吗? @Override public CompletableFuture delete(String id,Map 标头){...

回答 1 投票 0

Vert的未来

我有一个从处理程序获取List >的场景,现在必须返回Future > List > Futures = new ArrayList

回答 1 投票 -1

传递给CompletableFuture.allOf()的所有期货都将运行吗?

因此,我有一些要运行的期货,即使有些失败,我也希望所有人都有机会运行。所以,如果我这样做:CompletableFuture.allOf(futures).join()会是这种情况吗?我的理由是...

回答 1 投票 4

在CompletableFuture上同步使用acceptEither进行任务调度

我正在通过CompletableFuture API学习并发性。假设我有两项任务:一项耗时250毫秒,另一项耗时2500毫秒。在以下代码中:Supplier > ...

回答 1 投票 1

CompletableFuture链接

我正在寻找有关链接多个CompletableFutures方法的建议。假设我需要执行3次操作。搜索表单主表(如果主表中不存在数据,则插入...

回答 1 投票 0

为什么CompletableFuture中的断点也停止在主线程中执行?

我正在尝试一个简单的代码片段,以检查CompletableFuture是否确实在单独的线程中工作。类Scratch {public static void main(String [] args){CompletableFuture.runAsync(()-> ...

回答 1 投票 0

正在测试CompletableFuture.allOf。加入需要永远

我正在尝试测试使用CompletableFuture.allOf的方法。我模拟期货,以便它们在加入时返回所需的价值。由于某些我无法理解的原因。结果的join()需要...

回答 1 投票 0


正确覆盖CompletableFuture.cancel

我注意到,如果将来调用thenApply,则覆盖cancel方法无效。派生的未来不知道原始文档具有此类替代。代码...

回答 2 投票 3

调用列表 具有超时并收集结果

我正在尝试以每个工作者2秒钟的超时来停止许多Worker实例,我希望其中一些实例会失败。我想实现以下目标,但我知道这是不好的方法。我不能使用...

回答 2 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.