completable-future相关内容

列表<未来>到未来<列表>Java中的序列

我正在尝试将 List> 转换为 CompletableFuture>.当您有许多异步任务并且需要获取所有任务的结果时,这非常有用. 如果其中任何一个失败,那么最终的未来就会失败.这就是我实施的方式: public static CompletableFuture>序列2(列表> com,ExecutorService exec){如果(com.isEmpty()){抛出新的 Illeg ..
发布时间:2021-11-25 20:26:13 Java Web开发

android:使用 CompletableFuture 从 Room 加载列表?

由于 AsyncTask() 方法已被弃用,我正在尝试替换它.以前 AsyncTask() 用于将 CardView 从 Room 数据库加载到 RecyclerView 列表中.我正在尝试使用 CompletableFuture() 作为替代,但该列表未加载.“List getAllCards()"的 Dao 方法;在 Android Studio 中给出错误消息“从未使用过该方法的返回值";所 ..
发布时间:2021-11-02 22:14:14 其他开发

使用 Spring App 中的期货处理并行异步操作

我有一个包含 +1M 条目的数据库,我正在以块的形式查询数据库(假设 chunkSize = 1000). 迭代这个 1000 块,我想为每个实体向rabbitMQ 发布一条消息,将这个块的所有期货收集到一个数组/列表中. 等待这个futures数组,直到所有futures都完成/失败,然后把这个1000的数组过滤成两个新的list(successList,failureList),然 ..
发布时间:2021-08-20 19:53:41 其他开发

CompletableFuture如何先返回FALSE或等到全部完成后再返回TRUE

我有些奇怪的情况,似乎不允许这种钉子钉入任何已广泛建立的CompletableFuture孔中. 在一个用于评估返回的布尔值的主要方法中,我想允许对三种不同方法的调用以异步方式完成.这三种方法都可以返回TRUE或FALSE. 如果 any 返回FALSE,我希望评估结果除去其余部分,然后简单地返回该FALSE值.关键是,它可以是三个中的任何,不一定是第一个. 但最重要的是,我需要评估,直 ..
发布时间:2021-04-23 20:09:11 其他开发

在传播结果或错误时如何调用CompletableFuture回调?

我正在尝试.exception和.handle,但是那些似乎不起作用.在scala中,您可以在将来使用闭包调用方法,就像close块一样(它在出现异常并成功运行时运行),并按原样在链上传播异常或成功. 我尝试过了... CompletableFuture未来= newFuture.handle((r,e)-> {if(r!=空)返回r;否则if(e!= null)返回e ..
发布时间:2021-04-23 20:09:03 其他开发

返回包含CompletableFutures列表的CompletableFuture

我正试图使对多个API的调用更快. 在下面的代码中, getFilteredEvents 是当前同步的版本.我感觉 map(x-> x.getFilteredEvents(eventResearch))操作将等待每个API的响应(它使用 RestTemplate.exchange()内部),然后再构建下一个要返回的 List .一种解决方案可能是在单独的线程上启动 map 调 ..
发布时间:2021-04-23 20:08:57 其他开发

让CompletableFuture例外地()处理supplyAsync()异常

问题很简单:我正在寻找一种与 CompletableFuture#supplyAsync 一起使用 CompletableFuture#exceptionally 的优雅方法.这是行不通的: private void didNotCompile(){CompletableFuture悲伤= CompletableFuture.supplyAsync(()-> throwSom ..
发布时间:2021-04-23 20:08:51 其他开发

最后如何访问多个Completablefuture Stage变量

我正在尝试在completablefuture管道的末尾使用多个不同的变量.很难解释.这是我的示例: private void test(){lib.getHumanFromDatabase().thenApplyAsync(human-> {//从数据库中返回一个人返回人类},执行者).thenComposeAsync(humanFromDb-> {//设置人的新名字humanFromDb. ..
发布时间:2021-04-23 20:08:45 其他开发

作者的理由是正确的,然后使用thenCompose而不是thenComposeAsync

这个问题不同于 Java8 thenCompose和thenComposeAsync之间的区别因为我想知道作者使用 thenCompose 而不是 thenComposeAsync 的原因. 我正在阅读《现代Java的实际应用》,并且在405页上看到了这部分代码: 公共静态列表findPrices(字符串产品){ExecutorService执行程序= Executors ..
发布时间:2021-04-23 20:08:42 其他开发

Return CompletableFuture< Void>或CompletableFuture<?> ;?

我想编写一个异步方法,该方法返回 CompletableFuture .未来的唯一目的是跟踪方法的完成时间,而不是结果.返回 CompletableFuture 或 CompletableFuture 会更好吗?是否有理由偏爱另一个,或者它们可以互换? CompletableFuture 本身从其许多方法返回 CompletableFuture . jav ..
发布时间:2021-04-23 20:08:39 其他开发

超时后在Java CompletableFuture中停止线程

我的Java代码中有一个异步链,我想在某个超时后停止所以我创建了一个带有一些线程的threadPool,并这样称呼CompletableFuture ExecutorService池= Executors.newFixedThreadPool(10); 比我有一种循环方法,一旦所有CompletableFutures完成,它就会再次从db中加载数据并执行一些任务 Completable ..
发布时间:2021-04-23 20:08:33 其他开发

CompletableFuture循环:如何收集所有响应并处理错误

我试图在循环中为 PUT 请求调用rest api.每个调用都是一个 CompletableFuture .每次api调用都会返回 RoomTypes.RoomType 类型的对象 我想收集响应(成功和错误都回复)在不同的列表中.我该如何实现?我确定我无法使用 allOf ,因为如果有的话,它不会获得所有结果一个呼叫无法更新. 如何记录每个呼叫的错误/异常? public v ..
发布时间:2021-04-12 18:54:21 其他开发