CompletableFuture和垃圾收集

文章/答案/技术大牛

发布

1回答

java、asynchronous、garbage-collection、completable-future

我想启动许多一次性的异步CompletableFutures，如下所示： for (Job job : jobs) { .whenComplete(this::doSomething); } 理想情况下，可以在whenComplete完成后对这些CompletableFutures进行垃圾回收。但是，由于我没有存储引用，是否存在预先收集它们的风险？

浏览 17提问于2019-02-16得票数 6

回答已采纳

1回答

从垃圾收集中逐出非直观对象

java、garbage-collection、completable-future

我正在调试内存泄漏，不得不深入到CompletableFuture内部。有一段代码(CompletableFuture.uniComposeStage)：UniRelay<V> copy = new UniRelay<V>(d

浏览 4提问于2017-06-13得票数 5

回答已采纳

1回答

Spring中的CompletableFuture

java、completable-future

我正在考虑使用CompletableFuture开始处理数据库中的某些内容。操作将花费几秒钟时间，但我希望将控制权返回浏览器，而不等待此操作完成。我的问题是:这安全吗？是否存在由于初始请求返回响应而导致我的Asynchronous任务被垃圾收集的风险？

浏览 1提问于2018-01-19得票数 0

2回答

CompletableFuture链未完成的->垃圾收集器？

java、multithreading、asynchronous、garbage-collection、completable-future

如果我有一个(或多个) CompletableFuture尚未启动，并且在该方法上有几个thenApplyAsync()，则为anyOf()-methods。也许我们需要更多关于join()上下文的信息。连接在线程中，是最后一个命令，没有副作用。我想，当CompletableFuture进入下一个链式CompletableFuture

浏览 18提问于2021-11-19得票数 0

回答已采纳

1回答

从CompletableFuture.allOf()执行中收集引发的异常

java、asynchronous、completable-future、java-threads

<Void> process1 = CompletableFuture.runAsync(() -> { throw new RuntimeException("Exception 1"); CompletableFuture<Void> process2 =CompletableFuture<Void> proce

浏览 1提问于2020-02-10得票数 4

回答已采纳

1回答

将List<CompletableFuture<T>>转换为CompletableFuture<List<T>>

java、asynchronous、java-8、completable-future

我有一个返回CompletableFuture<T>的doTransmit方法。我想在一个循环中调用doTransmit，收集所有的CompletableFuture<T>并将其转换为一个CompletableFuture<List<T>>，当所有收集的List<T>都已被解析时，它将使用CompletableFuture<T>进行解析。completableFutures.forEach(

浏览 2提问于2019-01-25得票数 1

3回答

在大量任务中使用CompletableFuture和线程池

java、multithreading

MyPublisher myPublisher; private final Map<String, List<CompletableFuturemyPublisher; } CompletableFuture<Void> future = C

浏览 3提问于2021-09-23得票数 0

1回答

收集所有CompletableFuture.allOf的可移植性

java、asynchronous、promise、java-8

我希望执行所有这些异常，并收集所有可能的异常，并仅用一个异常包装它。但是，收集的Throwable对象看起来可能会被删除 (!?)，就像被弱引用引用一样。最好用例子来解释这一点。我们检查异常，然后列出所有收集到的异常。因为我们想收集错误，所以我们使用handle方法。请注意，exeptionally()和whenComplete()也会发生同样的情况。然后，我们组成一个CompletableFuture的所有输入期货。当完成时，即当所有输入都被处理时，我们决定应该抛出一个异常；如果<em

浏览 5提问于2015-01-08得票数 2

回答已采纳

2回答

在Java中使用什么等同于在Javascript中使用异步等待？

java、async-await

public class main { ... ... ... ... public static MaxSubSequence cl

浏览 46提问于2021-06-19得票数 0

2回答

在CompletableFuture链中关闭外部进程

java、java-8、completable-future

我正在寻找更好的方法来“关闭”一些资源，在这里破坏外部Process，在CompletableFuture链中。现在，我的代码大致如下所示：{ return CompletableFuture.supplyAsync( try是

浏览 5提问于2016-11-16得票数 2

回答已采纳

1回答

java流:自定义收集器

java、java-stream

这是我的流： .iterate(1, n -> n < resultSet.getTotalCount.mapToObj(pageNumber -> this.buildCompletableFutureofResultSetType(oid, pageNumber, pageSize));public static Complet

浏览 0提问于2021-06-14得票数 2

1回答

如何让CompletableFuture在完成后被垃圾回收回收？

java、completable-future

我基于java的CompletableFuture构建了一个任务链，它可能非常非常长。我的问题是，CompletableFuture中的每个任务都是一个内部类UniCompletion，并且它包含对源CompletableFuture的引用，因此不可能对已完成的CompletableFuture进行垃圾回收。) { AtomicReference&

浏览 121提问于2020-05-16得票数 4

回答已采纳

2回答

java.util.concurrent.CompletableFuture#allOf的目的是什么？

java、java-8、completable-future

如果我有Collection<CompletableFuture<MyResult>>，我希望将其转换为CompletableFuture<Collection<MyResult>>。但是CompletableFuture#allOf有结果类型Void，所以调用它之后就会得到“无结果”。我有一个疑问，CompletableFuture#allOf刚刚返回的未来威奇是否已经完成，毕竟在收集。所以我可以调用CompletableFuture#a

浏览 5提问于2015-09-13得票数 3

1回答

CompletableFuture:转换与组合

java、mapping、completable-future

首先，我们与每一家商店联系，得到一个包含非折扣价格和折扣类型的响应，而不是将响应解析为Quote对象，并将其传递给远程折扣服务，后者返回一个已折扣价格的字符串。::join)} 我的问题不是thenApply和thenCompose之间的区别。我相信，后者是用来避免像CompletableFuture<CompletableFuture<...>>这样的嵌套结构。但是，我不明白的是，为什么我们需要在这里创建另一个级别的Comp

浏览 2提问于2020-05-18得票数 2

回答已采纳

2回答

需要帮助理解可用JVM“垃圾收集算法”和“垃圾收集器”

java、garbage-collection、jvm

我通过链接来理解可用的JVM垃圾收集算法，结果搞糊涂了。我认为这些是垃圾收集器的类型，它实现了一些特定的算法(我不知道的算法名称)。另外，我正在阅读在上发布的关于JVM垃圾收集的白皮书，但是无法明确区分垃圾收集算法和</e

浏览 2提问于2015-03-31得票数 2

1回答

CompletableFuture:运行期货列表、等待结果和处理异常的正确方法

java、asynchronous、design-patterns、java-8、completable-future

我有一个遗留代码，它有十几个数据库调用来填充一个报表，我尝试使用CompletableFuture来减少它所花费的大量时间。 CompletableFuture section1Future = CompletableFuture.supplyAsync(() -> populateSection1(参数))；CompletableFuture section2Future = <

浏览 0提问于2018-11-10得票数 6

回答已采纳

2回答

Java垃圾收集器是特定于主要GC的吗？

java、garbage-collection

因此，有两种类型的垃圾收集过程JVM所做的:小GC和主要GC。不同类型的垃圾收集器有:串行垃圾收集器、并行垃圾收集器、CMS垃圾收集器、G1C垃圾收集器等。这些垃圾收集器根据其实现的不同算法对垃圾收集过程进行了不同的处理。根据CMS的Oracle文档，次要集合可以与正在进行的主要周期交织，

浏览 0提问于2019-08-31得票数 4

回答已采纳

1回答

Java 8用CompletableFuture::join维护流顺序

java、java-8、java-stream、completable-future

我希望确保在使用Completablefuture::join时，在输入查询流的顺序中收集这些需求的结果。我的代码是这样的： .map(query -> CompletableFuture.supplyAsync(() -> {) { } .map(CompletableFuture如果我在<

浏览 0提问于2015-10-27得票数 4

回答已采纳

1回答

在等待完成时，CompletableFuture.allOf()比使用CompletableFuture.join()的循环有什么优势吗？

java、asynchronous、concurrency、completable-future

我将所有这些异步调用存储在List<CompletableFuture<X>> list上。我想收集所有的结果，所以我需要等待所有这些调用完成。一种方法是创建一个CompletableFuture.allOf(list.toArray(...))... 另一种方法是使用：list.stream.map(cf -> cf.join())...我只是想知道，与直接等待单个CompletableFuture完成相比，创建全局CompletableFuture并等待它完成(当所有单独

浏览 4提问于2021-10-29得票数 3

回答已采纳

1回答

CompletableFutures和基于内部值的过滤

java、lambda、filter、java-8、completable-future

我现在有点困惑，所以我有一个应该返回CompletableFuture<List<A>>的方法CompletableFuture<List<String>> toReturn = asyncCall<List<ComputableFuture<A>>>转换为CompletableFuture<List<A>> 基本上，我的目的是过滤从optionalValue.orElse(null)中出现的null值，在将其全部

浏览 2提问于2016-11-21得票数 2

点击加载更多