completable-future 相关问题

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

流对象,发送具有可完成的未来的请求并将结果分配给对象

我有一个对象签名者列表。对于每个签名者,我需要发出ReST请求以获取其签名URL。我正在尝试使用可完成的期货,所以所有的ReST请求都可以发送...

回答 1 投票 1

CompletableFuture#exceptionly rethrow checked exception

如果我得到一个特定的异常,假设我想恢复一些值,否则返回失败的未来与异常。我希望这样的事情:public static void main(String [] ...

回答 1 投票 0

如何将completableFuture.supplyAsync()的返回类型分配给对象?

我在foreach循环中定义了completableFuture.supplyAsync(),因此每个条目(每个异步任务)添加一个列表,我需要从...获取最终列表(在所有异步任务添加列表之后)

回答 2 投票 1

foreach循环中的completablefuture runasync

我在foreach循环中定义了completablefuture runasync()任务。我需要在nosql db中插入记录,并且需要在sql db中更新与'processed'相同的插入记录(迁移...

回答 1 投票 0

如何抽象捕获异常CompletableFutures以调用方法

好的,我有像CompletableFuture fetchCar(int id)这样的方法; CompletableFuture runSomething(Something t,Extra d); CompletableFuture invoke();我想要一个可以使用的方法......

回答 1 投票 1

Java Future:如何在执行异步调用时解除阻塞主线程

当我使用ExecutorService进行异步调用时,它返回Future Object。根据它返回的布尔值,我必须记录异步调用的状态。但是当我尝试调用方法get方法时......

回答 3 投票 1

为什么ForkJoinPool使用ThreadPerTaskExecutor?

我们在两个CPU环境中运行Java中的Akka应用程序,我们观察到每次告诉都会启动一个新的Thread而不是从池中获取它们。 Akka默认调度程序使用ForkJoinPool ...

回答 1 投票 2

使用Java中的反应包装器使用非阻塞IO逐行读取文件

有没有办法逐行读取本地文件而不阻塞任何线程(后台线程池计为阻塞)使用内置的CompletableFuture或反应流库如RxJava或...

回答 1 投票 -2

列出CompletableFuture

您能告诉我如何在Parent CompleFuture中等待CompletableFuture列表,收集结果并将其返回吗? CompletableFuture 未来= ......

回答 1 投票 -1

处理使用可完成期货的实体清单

我有一个类型为T的实体列表。我还有一个功能接口,它充当供应商,它具有在实体上执行任务的方法,并返回结果R,如下所示:R performTask(...

回答 1 投票 1

.exceptionally()会捕获嵌套期货中抛出的异常吗?或者放在哪里正确.exceptionally()

foo.thenCompose(fooResponse - > {... return bar.thenCompose(barResponse - > {...});})。exceptionally(e - > {...});这个.exceptionally()是否也会捕获从...抛出的异常

回答 2 投票 1

具有超时功能的可完成的未来

我是新的可持续未来。我试图为一个元素列表(它们是参数)调用一个并行方法,然后将结果组合起来创建一个最终响应。我也想设置......

回答 2 投票 1

具有突变的CompletableFuture的身份函数

我正在使用CompletableFutures来处理我的REST调用。我有一个案例,我必须做两个调用:一个给出一个结果,我会多次使用;和另一个用...修改数据库

回答 1 投票 0

具有CompletableFuture的MDC记录器

我正在使用MDC Logger,除了一个案例外,它对我来说非常有用。无论在代码中我们使用CompletableFuture,对于创建的线程,MDC数据都不会传递给下一个......

回答 1 投票 1

.exceptionally()会捕获嵌套期货中抛出的异常吗?或者放在哪里正确.exceptionally()

foo.thenCompose(fooResponse - > {... return bar.thenCompose(barResponse - > {...});})。exceptionally(e - > {...});这个.exceptionally()是否也会捕获从...抛出的异常

回答 2 投票 1

如何使用ExecutorService进行轮询直到结果到达

我有一个场景,我必须轮询远程服务器检查任务是否已完成。一旦有,我会进行不同的调用以检索结果。我原本以为我应该用...

回答 2 投票 5

你如何等待所有异步调用在Java中完成?

从概念上讲很简单。我们有一个巨大的遗留Java站点,它使用NO线程/异步。登录需要永远,因为它会对不同的微服务进行十几次调用,但所有这些调用都是同步的......

回答 1 投票 5

如何收集按顺序调用异步API的结果?

我有一个异步API,它基本上通过分页公共CompletableFuture返回结果 getNext(int startFrom);每个Response对象都包含一个来自...的偏移列表

回答 2 投票 2

ExecutorService与CompletableFuture

我一直在尝试实现一个异步过程,其中父方法调用一个子方法,然后调用三个不同的方法。我希望所有这一切都完成......

回答 3 投票 4

如何组合List(对我来说)或java中的其他类型的多个CompletionStage响应

我正在尝试创建多个类型为List的CompletionStage,例如。 CompletionStage >。最后我想合并所有类型的响应 >进入一个清单......

回答 2 投票 1

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