我想做一些事情作为CompletableFuture列表中将来完成的订单
我有一些这样的服务回报 CompletableFutures Set>期货= service.getSomething();for(CompletableFuture Future:Futures){System.out.println(future.get());} 此代码显示值迭代顺序.但是我想像使用 Compl
..
completable-future相关内容
为什么在CompletableFuture中时，我的Thread.sleep会结束进程?
我正在尝试创建CompleteableFuture.我只是想注销一些声明.这是我的代码: 静态CompletableFuturecreateFuture(字符串名称){返回CompletableFuture.supplyAsync(()-> {尝试 {System.out.println(“任务执行开始.");//Thread.sleep(2000);System.out.pr
..
在传播结果或错误时如何调用CompletableFuture回调?
我正在尝试.exception和.handle，但是那些似乎不起作用.在scala中，您可以在将来使用闭包调用方法，就像close块一样(它在出现异常并成功运行时运行)，并按原样在链上传播异常或成功. 我尝试过了... CompletableFuture未来= newFuture.handle((r，e)-> {if(r！=空)返回r;否则if(e！= null)返回e
..
使用另一个CompletableFuture结果完成CompletableFuture
我正在以这种方式进行异步http调用 public CompletableFuturedoPost(String path，String json){CompletableFuture结果= new CompletableFuture();请求request = new Request.Builder().url(this.address + path)
..
返回包含CompletableFutures列表的CompletableFuture
我正试图使对多个API的调用更快. 在下面的代码中， getFilteredEvents 是当前同步的版本.我感觉 map(x-> x.getFilteredEvents(eventResearch))操作将等待每个API的响应(它使用 RestTemplate.exchange()内部)，然后再构建下一个要返回的 List .一种解决方案可能是在单独的线程上启动 map 调
..
根据某些条件停止/完成循环的CompletableFuture
CompletableFuture未来= CompletableFuture.completedFuture(null);for(int _retrial = 1; _retrial
..
为什么即使我不调用get()或join()，此CompletableFuture也能正常工作?
我在学习 CompletableFuture 时遇到了一个问题. get()/ join()方法正在阻止调用.如果我都不给他们打电话怎么办? 此代码调用 get(): //情况1-使用get()CompletableFuture.runAsync(()-> {尝试 {Thread.sleep(1_000L);} catch(InterruptedException e){e.printSt
..
最后如何访问多个Completablefuture Stage变量
我正在尝试在completablefuture管道的末尾使用多个不同的变量.很难解释.这是我的示例: private void test(){lib.getHumanFromDatabase().thenApplyAsync(human-> {//从数据库中返回一个人返回人类}，执行者).thenComposeAsync(humanFromDb-> {//设置人的新名字humanFromDb.
..
Return CompletableFuture< Void>或CompletableFuture<?> ;?
我想编写一个异步方法，该方法返回 CompletableFuture .未来的唯一目的是跟踪方法的完成时间，而不是结果.返回 CompletableFuture 或 CompletableFuture 会更好吗?是否有理由偏爱另一个，或者它们可以互换? CompletableFuture 本身从其许多方法返回 CompletableFuture . jav
..
使用Quarkus/Mutiny在Reactive REST GET端点中分发CompletionStage/CompletableFuture API服务
在实现响应式REST GET端点之后使用Quarkus/Mutiny使用回调结构并检查就像某种回调一样).
..
超时后在Java CompletableFuture中停止线程
我的Java代码中有一个异步链，我想在某个超时后停止所以我创建了一个带有一些线程的threadPool，并这样称呼CompletableFuture ExecutorService池= Executors.newFixedThreadPool(10); 比我有一种循环方法，一旦所有CompletableFutures完成，它就会再次从db中加载数据并执行一些任务 Completable
..
CompletableFuture循环:如何收集所有响应并处理错误
我试图在循环中为 PUT 请求调用rest api.每个调用都是一个 CompletableFuture .每次api调用都会返回 RoomTypes.RoomType 类型的对象 我想收集响应(成功和错误都回复)在不同的列表中.我该如何实现?我确定我无法使用 allOf ，因为如果有的话，它不会获得所有结果一个呼叫无法更新. 如何记录每个呼叫的错误/异常? public v
..
在控制器中使用@Async和CompletableFuture可以提高我们api的性能?
我要实现的目标是通过使用@Async和CompletableFuture来获得更好的性能，从而通过这种简单的方式使用多线程将我的RESTApi用作我的控制器? 这是我的工作，这是我的控制器: @PostMapping("/store")@异步public CompletableFuture
..
如果链中的第一个方法是异步的，一连串的方法调用(CompletableFuture API)是否会异步执行?
我正在研究CompletableFuture API，并且有一个示例: CompletableFuture.completedFuture(url).thenComposeAsync(this :: readPage，executor).thenApply(this :: getImageURLs).thenApply(this :: saveFoundImages)..... 我有一个问
..
CompletableFuture，主要永不退出
我正在学习Java 8，以及"CompletableFuture"的详细信息. 跟随这个有趣的教程: https://www.callicoder.com/java-8-completablefuture-tutorial/ 我编写了以下Java类: package parallels; import java.util.ArrayList; import java.util.Lis
..
Spring如何从返回CompletableFuture对象的端点获取结果?
在下面的代码中，当命中端点getPerson时，响应将为Person类型的JSON. Spring如何将CompletableFuture转换为Person? @RestController public class PersonController { @Autowired private PersonService personService;
..
直接从CompletableFuture.thenAccept返回值
我试图像这样从我的CompletableFuture返回列表: public List get() { CompletableFuture> providersResponse = getSomeData(); return providersResponse.thenAccept((List provid
..
如何执行CompletableFuture数组并组合其结果
我正在研究Java 8 CompletableFutures，并且阅读(看到)我应该使用thenCompose而不是thenApply. 我已经将代码转换为使用thenCompose，但是我有一种错误的感觉. 这是我的控制代码... final CompletableFuture> extractor = get(htmlPageSource); @Su
..
如何调试CompletableStage死锁？
我最近遇到的最困难的调试问题是异步操作之间的死锁。例如，给定两个 CompletionStage 链，其中第一条链调用依赖于第二条链完成的方法，第二条链调用依赖于完成条的方法第一链的。在现实生活中这不是很明显，因为这种依赖关系往往被隐藏起来，有时僵局涉及三个以上的参与者。 部分问题是没有找出 CompletableStage 正在等待什么的方法。这是因为操作引用了 CompletableSt
..
轴突未来发展
当我尝试在Axon上使用CompletableFuture时遇到了问题。 例如： CompletableFuture future = CompletableFuture.supplyAsync（（）-> { log.info（“开始处理目标：{}”，target.toString（））； 返回新的Event（）； }，threadPool）； future.the
..