completable-future 相关问题

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

如何在springboot async的void方法中使用CompletableFuture?

我应该如何在springboot async的void方法中使用CompletableFuture。请举例说明。

回答 1 投票 0

如何等到一系列嵌套的 CompletableFutures 全部完成?

我有一个增强现实应用,其中ARObject是一个POJO: class ARObject { CompletableFuture 纹理; CompletableFuture material; ModelRenderable ...

回答 1 投票 0

同步异步后端

我需要创建一个REST端点,它将 "同步 "来自JMS后台服务的请求和响应。换句话说,我的端点应该向JMS输入队列发送消息,等待......。

回答 1 投票 0

有没有办法给Rest Template动态超时?

我使用Spring Rest模板和apache的PoolingHttpClientConnectionManager来进行API调用。我正在做的项目需要为每个HTTP连接设置自定义超时。

回答 1 投票 0

有没有一个好的方法可以将FutureLocal.java添加到自定义的Future.java扩展CompletableFuture中?(示例代码如下)

我有下面的代码,这是一种接近,除了当我调用super.thenCompose和它返回一个CompletableFuture而不是我的自定义未来.java这是一种关键。我正试图...

回答 1 投票 0

调用一个使用CompletableFuture的thenAccept()的方法。

我有一个 rest API 函数,它返回一个类型为 DeferredResult 的对象。 import org.springframework.web.context.request.async.DeferredResult; public DeferredResult apiMethod{ ...

回答 1 投票 0

CompletableFuture:转化与构成

请考虑 "Modern Java in Action "一书中的一个例子(第2版,清单16.16,第405页)。在那里,我们有三个映射操作来获得产品的折扣价格列表......。

回答 1 投票 1

运行线程时的异常处理

我有一个应用程序,它有一个kafka消费者,并根据它收到的数据更新Elastic搜索。我的问题是,当ES宕机时,kafka消费者完全停止了,并且...

回答 1 投票 1

只有当前一个期货发生异常时,才会执行一个可完成的期货列表。

我有一个可完成的未来列表,我想从第一个未来开始,如果有任何完成异常,我想尝试列表中的下一个未来,以此类推,直到我用尽 ...

回答 1 投票 0

当异步方法中的一个线程发生异常时,终止所有线程。

如果在异步方法中的任何一个线程遇到异常,是否可以立即中断所有其他线程的执行?该方法返回一个completableFuture对象。...

回答 1 投票 0

如何等待被封闭的异步块完成?

我在使用stream().forEach时遇到了一个问题,它在方法返回前没有及时完成,是这样的:我的实体......。@Getter @Setter @AllArgsConstructor @NoArgsConstructor @ToString public class ...

回答 2 投票 0

具有supplyAsync的CompletableFuture无法按预期方式工作

我正在使用Java CompletableFuture进行一些实验。这是代码,公共类SpringBootAsyncApplication {public static void main(String [] args){CompletableFuture ....

回答 1 投票 0

在Java中具有可完成的将来或NodeJ是更好的选择的IO密集型服务是否可能获得高吞吐量(4-5 TPS)

我们需要开发一种服务,该服务应能够处理大量流量,即大约5TPS。我们必须进行3-4个并行的下游Rest调用(下面提到的是带有2个Rest调用的POC)-> ...

回答 1 投票 0

[如何使用CompletableFuture在Java 8中将此代码转换为异步代码?我正在使用Spring Boot

这里是需要异步的代码段:List courses = Lists.newArrayList(); Map > result = Maps.newHashMap();对于(Map

回答 1 投票 1

与CompletableFuture异步后如何保持干净的代码流?

我遇到了CompletableFutures的问题。我有一个基于API的基于JAX RS的REST端点,我需要对该API进行3次连续调用。电流看起来像这样:...

回答 1 投票 1

使用JDK8流和CompletableFuture调用WebService和REST API

我需要进行SOAP调用,然后在REST调用中处理SOAP调用的结果。每组呼叫均基于一批记录。我完全迷失在试图得到...

回答 1 投票 0

带有CompletableFuture的Spring boot异步调用,异常处理

我有一个Spring引导服务,其中的一些代码如下所示,用于并行异步调用:CompletableFuture future1 = accountManager.getResult(url1); CompletableFuture future2 = accountManager.getResult(url2); ...

回答 1 投票 0

从数据库中获得具有可完成的未来的结果

我正在使用Spring Boot和Spring Data Jpa,并且我具有由db中要并行运行的3个请求组成的逻辑。我想为此使用CompletableFuture。最后,我需要...

回答 1 投票 0

如何使CompletableFuture在完成后通过垃圾回收进行回收?

我基于Java的CompletableFuture构建了一个任务链,它可能会非常长。我的问题是CompletableFuture中的每个任务都是一个内部类UniCompletion,它包含对源代码的引用...

回答 1 投票 1

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

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

回答 1 投票 4

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