completableFuture whenComplete奇怪的行为
CompletableFuture是Java 8引入的一个类，用于支持异步编程和处理异步任务的结果。CompletableFuture类提供了丰富的方法来处理异步任务的结果，其中之一就是whenComplete方法。
whenComplete方法是CompletableFuture类中的一个回调方法，它接收一个BiConsumer参数，用于处理异步任务的结果和异常。当异步任务完成时（无论是正常完成还是异常完成），whenComplete方法都会被调用。
当异步任务正常完成时，whenComplete方法会接收到任务的结果和null作为参数。我们可以在whenComplete方法中对任务的结果进行处理，例如打印结果、保存结果等。
当异步任务异常完成时，whenComplete方法会接收到null和任务的异常作为参数。我们可以在whenComplete方法中对异常进行处理，例如打印异常信息、记录日志等。
CompletableFuture的whenComplete方法的行为可能会被认为是奇怪的，因为它不会阻塞主线程，而是在异步任务完成后立即执行。这意味着当主线程调用whenComplete方法时，它会继续执行后续的代码，而不会等待异步任务的完成。
当然，CompletableFuture类还提供了许多其他方法来处理异步任务的结果，例如thenApply、thenAccept、thenRun等。这些方法可以根据具体的需求来选择使用。
推荐的腾讯云相关产品：腾讯云函数（云原生Serverless计算服务），腾讯云COS（对象存储服务），腾讯云数据库MySQL版（关系型数据库服务）。
腾讯云函数产品介绍链接地址：https://cloud.tencent.com/product/scf 腾讯云COS产品介绍链接地址：https://cloud.tencent.com/product/cos 腾讯云数据库MySQL版产品介绍链接地址：https://cloud.tencent.com/product/cdb
相关·内容
我有以下代码：
public final class Start {
private static final CountDownLatch FINAL_THREAD = new CountDownLatch(1);
private static String getValue() {
System.out.println("Waiting...");
try {
Thread.sleep(Duration.ofSeconds(1).toMillis());
return
浏览 19提问于2021-05-13得票数 1
我在使用completableFutures时遇到了一些奇怪的行为，请参阅下面的代码片段，以便更容易和更好地理解。我遍历消息列表，并对每条消息调用handleMessage。handleMessage方法首先调用getDataContentIdByService，最后调用mappingService.process方法。 但问题是，一旦getDataContentIdByService方法处理完成，在mappingService.process方法的执行完成之前，调用就会返回到whenComplete阶段。 我想要的是getDataContentIdByService和mappingServ
浏览 45提问于2021-07-16得票数 1
回答已采纳
我遇到了Java 8 CompletableFuture thenCompose方法的奇怪行为。我有两个测试，它们的执行顺序不同。这两个测试都模拟了在CompletableFuture中生成的thenCompose中的失败。
@Test
public void completedAfter() {
CompletableFuture<String> future1 = new CompletableFuture<>();
CompletableFuture<String> future2 = new CompletableFuture<
浏览 6提问于2015-01-02得票数 7
回答已采纳
当我使用CompletableFuture.allOf()组合javadoc中描述的独立的可完成期货时，在提供给该方法的所有期货之后，它并不能可靠地完成。例如：
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class CompletableFutureTest {
public static void main(String[] args) throws ExecutionException, InterruptedExcep
浏览 13提问于2017-11-21得票数 7
回答已采纳
我希望在另一个CompletableFuture完成后执行一个CompletableFuture，而不管第一个CompletableFuture是否异常完成(.thenCompose()只在执行正常完成时运行)。
例如：
CompletableFuture.supplyAsync(() -> 1L)
.whenComplete((v, e) -> CompletableFuture.runAsync(() -> {
try {
Thread.sleep(1000);
System.out.println
浏览 3提问于2014-12-20得票数 10
回答已采纳
如何在创建CompletableFuture的原始线程中运行CompletableFuture的whenComplete？
// main thread
CompletableFuture
.supplyAsync(() -> {
// some logic here
return null;
}, testExecutorService);
.whenComplete(new BiConsumer<Void, Throwable&
浏览 0提问于2019-02-04得票数 0
在java中使用CompletableFuture时遇到了问题。我有两个select请求，这些请求在接收服务器的响应时被填充。
在连接线程(线程-1)(使用反应堆)中，我使用：
if(hasException) {
selectFuture.completeExceptionally(new ClientException(errorCode));
} else {
System.out.println("Before complete future");
selectFuture.complete(result);
System.out.println
浏览 4提问于2016-11-03得票数 5
回答已采纳
编辑:在堆栈过流上交叉发布这个问题。
假设我有一个函数，它接受一个FileInputStream，使用后台的文件数据执行一些操作，并返回一个CompletableFuture<Void，在后台操作完成后将完成该操作：
CompletableFuture<Void> asyncFileOperation(FileInputStream in) {
var cf = new CompletableFuture<Void>();
// ...
return cf;
}
FileInputStream是一种在不再需要时必须关闭的资源。对于同步代码，我们将使用f
浏览 0提问于2021-08-08得票数 2
回答已采纳
演示代码如下所示：
@Test
public void testOrder2() throws InterruptedException {
ExecInfo execInfo = new ExecInfo();
CompletableFuture<Integer> dataFutrue = testOrderFunc(execInfo);
dataFutrue.handle((dataRet,err) -> {
System.out.println("test" + execInfo.cost);
re
浏览 4提问于2022-10-25得票数 0
回答已采纳
如何将在CompletableFuture.runAsync内的以下代码中遇到的异常传播到我的主线程？我想在我的主线程中捕获IllegalStateException。 CompletableFuture.runAsync(() -> {
// some business logic which needs to run indefinitely
}).exceptionally(ex -> {
// ex.printStackTrace();
throw new IllegalStateException("Failed to proce
浏览 47提问于2020-08-04得票数 1
回答已采纳
CompletableFuture应用程序接口允许我们使用thenCompose链接另一个未来：
CompletableFuture<String> future1 = submit("foo");
CompletableFuture<String> future2 = future.thenCompose((result) -> submit(result));
不过，这只适用于成功的响应。有没有办法做到这一点，但也包括异常处理？
例如：
CompletableFuture<String> future1 = submit("
浏览 26提问于2020-03-07得票数 0
回答已采纳
在java-9中，引入了CompletableFuture类中的CompletableFuture：
public CompletableFuture<T> completeOnTimeout(T value, long timeout,
TimeUnit unit) {
if (unit == null)
throw new NullPointerException();
if (result == null)
whenComplete(ne
浏览 1提问于2018-03-27得票数 15
我写了一个简单的程序
import java.util.concurrent.*;
public class TestCompletableFuture {
public static void main(String[] args) throws Exception {
CompletableFuture<Void> future = new CompletableFuture<Void>()
.whenComplete((res, exc) -> {
System.out
浏览 1提问于2022-11-20得票数 0
我是第一次使用CompletableFuture's whenComplete。 在我的用例中，我想调用REST api并获取其结果。对这些结果执行一些操作并返回输出。 我想使用CompletableFuture.supplyAsync()进行这个REST调用&使用whenComplete()来获取结果。 下面是我目前使用的示例代码： 1. String myOutput = null;
2. CompletableFuture.supplyAsync(() -> callMyRestService(myUrl))
3. .whenComplete((myResp
浏览 54提问于2021-11-15得票数 0
1回答
在spring boot应用程序中使用CompletableFuture时，我注意到在使用CompletableFuture异步运行的函数中发生了异常，但没有任何日志。函数执行停止，因此CompletableFuture已完成。为什么日志里什么都没有？当我在.runAsync中使用.whenComplete时，我能够记录错误。
void function() {
CompletableFuture
.runAsync(() -> runAsyncfunction())
.whenComplete((result, err) -> {//log the er
浏览 4提问于2021-11-04得票数 1
asyncConfiguration SdkAdvancedAsyncClientOption.FUTURE_COMPLETION_EXECUTOR的用途是什么？我们应该在哪些用例中使用它？
从FUTURE_COMPLETION_EXECUTOR上的java文档中，我看到：Configure the executor that should be used to complete the CompletableFuture that is returned by the service clients.我以为对异步结果的CompletableFuture的后续调用将在传入FUTURE_COMP
浏览 17提问于2019-07-13得票数 0
回答已采纳
1回答
我有一个创建异步任务并返回CompletableFuture的方法(可以由不同的线程并发调用)。我想通过使用whenComplete(...)链接任务来测量运行任务所需的时间如下所示：
public CompletableFuture<Result> createTask(...) {
CompletableFuture<Result> result = ...;
final long startTime = System.currentTimeMillis();
result.whenComplete((res, err) -> {
浏览 17提问于2016-07-23得票数 2
回答已采纳
我正在尝试返回一个CompletableFuture，它将返回来自亚马逊的响应。我的代码首先检查是否在本地缓存了响应。如果是，则返回响应，否则调用Amazon。注意:真实版本也将缓存从Amazon收到的响应，但我没有包括这一点，因为代码已经相当复杂。
有没有办法更改我的callAmazon方法的实现(或者重新组织代码)，这样我就不必“手动”将响应状态从amazonApi复制到finalResponse
我不想直接返回cacheCheck，因为我不希望调用者能够complete()它。
public CompletableFuture<Response> fetchProductLi
浏览 4提问于2016-11-22得票数 2
我正在对数据库进行多个异步调用。我将所有这些异步调用存储在List<CompletableFuture<X>> list上。我想收集所有的结果，所以我需要等待所有这些调用完成。
一种方法是创建一个CompletableFuture.allOf(list.toArray(...))...
另一种方法是使用：list.stream.map(cf -> cf.join())...
我只是想知道，与直接等待单个CompletableFuture完成相比，创建全局CompletableFuture并等待它完成(当所有单独的CompletableFuture都完成时)是否有什
浏览 4提问于2021-10-29得票数 3
回答已采纳
我的印象是，您在whenComplete中添加的任何内容都发生在一个与生成它的线程完全不同的线程上。但是我们今天发生了一个事件，看看我们的日志，似乎从whenComplete内部抛出的异常出现了冒泡，就好像异常被抛入了一个规则链(例如thenApply、thenCompose等)，并被一个exceptionally (在原始链中)捕获了一样。
这有可能吗？多么?
我希望答案是否定的，那是不可能的，而且有一些奇怪的事情正在发生/我们正在误读我们的日志或逻辑。
浏览 4提问于2022-07-26得票数 1
回答已采纳
下面是一个非常简单的代码片段：
String[] list = {"a", "b", "c"};
List<CompletableFuture<String>> completableFutureList = new ArrayList<>();
for (String s : list) {
completableFutureList.add(CompletableFuture.supplyAsync(() -> s)
.thenApply(String::toUpper
浏览 0提问于2019-01-25得票数 0
回答已采纳
来自CompletableFuture javadocs：
为非异步方法的依赖完成提供的操作可以由完成当前CompletableFuture的线程执行，也可以由完成方法的任何其他调用方执行。
查看CompletableFuture.complete()，它调用了postComplete()，它似乎从依赖链中弹出并试图完成它们。
为了测试我的理解，我编写了一个简单的程序。
import java.util.concurrent.*;
public class TestCompletableFuture {
public static void main(String[] ar
浏览 6提问于2022-11-20得票数 1
回答已采纳
在使用CompletableFuture将代码转换为非阻塞代码时，我面临一个问题。为了最小化问题的范围，我创建了一个，它在使用CompletableFuture时的行为有所不同。问题是CompletableFuture从Runnable委托中吞下了异常。
我在Runnable和ExecutorService之上使用委托来提供原始应用程序中需要的一些包装代码。
样本代码：
MyRunnable:我的示例runnable，它总是抛出异常。
公共类MyRunnable实现Runnable { @Override (){System.out.println(“这是我的线程抛出异常：”+ Threa
浏览 3提问于2018-08-31得票数 2
回答已采纳
1回答
我想启动许多一次性的异步CompletableFutures，如下所示： for (Job job : jobs) {
CompletableFuture.supplyAsync(() -> job.process())
.whenComplete(this::doSomething);
} 理想情况下，可以在whenComplete完成后对这些CompletableFutures进行垃圾回收。但是，由于我没有存储引用，是否存在预先收集它们的风险？
浏览 17提问于2019-02-16得票数 6
回答已采纳
给定存储库类，它返回一个单独的：
Single<SomeObject> find()
和返回浮点数的CompletableFuture：
CompletableFuture<Long> completableFuture
我想首先调用存储库方法，根据结果，我需要调用completableFuture。这是我的代码：
repository.find()
.flatMap(s -> {
CompletableFuture<Long> completableFuture = serviceReturningCo
浏览 1提问于2019-12-02得票数 0
回答已采纳
我有一些像这样的服务回报CompletableFutures
Set<CompletableFuture<String>> futures = service.getSomething();
for (CompletableFuture<String> future : futures) {
System.out.println(future.get());
}
此代码打印值迭代顺序。但是我想要像使用CompletionService.那样的快速结果打印
Set<CompletableFuture<String>> futu
浏览 4提问于2017-06-16得票数 1
回答已采纳
我正在研究Java 8 CompletableFuture (在Scala或JS等语言中的承诺)。
可能是我做错了什么，或者没有找到任何描述。在安装后返回的未来，很少会对其进行回调，从而返回完全独立的未来。
我要做一些单元测试：
public class FutureTest {
private boolean stage1;
private boolean stage2;
@Before
public void setUp() throws Exception {
this.stage1 = false;
this.stage
浏览 3提问于2015-05-15得票数 1
回答已采纳
我有2 CompletableFutures。task2只应在task1完成后才能启动。然后，我需要等待所有的任务完成。在下面的代码中，程序在task1结束后结束。task2启动，但未完成。知道为什么会这样吗？另外，为什么列表只包含一个条目，而我在代码中添加了2个条目？
代码：
public void testFutures () throws Exception {
List<CompletableFuture<Void>> futures = new ArrayList<>();
CompletableFuture<Void>
浏览 1提问于2020-11-26得票数 2
回答已采纳
我有这样的方法：
default <U> CompletableFuture<U> submit(Supplier<U> supplier) {
return CompletableFuture.supplyAsync(supplier, .....getThreadPool());
}
它被不同的类广泛使用，但是目前如果计算失败，就没有默认的日志记录。我的第一个方法是：
.exceptionally(throwable ->
.....handleThrowable(throwable, runnable);
浏览 1提问于2015-03-24得票数 5
回答已采纳
类CompletableFuture允许添加在将来调用complete(...)之后调用的操作。
我是否可以使用whenComplete(...)来添加多个BiConsumer操作，以便在完成将来时执行，并且在调用complete(...)方法时是否都执行？
浏览 2提问于2017-01-10得票数 2
回答已采纳
我有以下代码：
ConcurrentHashMap taskMap= new ConcurrentHashMap();
....
taskMap.compute(key, (k, queue) -> {
CompletableFuture<Void> future = (queue == null)
? CompletableFuture.runAsync(myTask, poolExecutor)
: queue.whenCompleteAsync((r, e) -> myTask.run
浏览 1提问于2017-09-04得票数 2
我想知道使用zip使用CompletableFuture的官方机制是什么。到目前为止，我只使用thenCombine操作符。这是我的例子。
@Test
public void zip() throws InterruptedException {
CompletableFuture<Either<Integer, String>> completableFuture = CompletableFuture.supplyAsync(this::getValue);
CompletableFuture<Either<Integer, String
浏览 0提问于2017-10-17得票数 1
我有一个发出HTTP请求的程序，在那里我可能需要尝试几个不同的服务器才能获得成功的响应。HTTP是异步的，所以我在发出请求时会得到CompletableFuture结果。
当我得到一个糟糕的响应状态代码时，我可以很容易地尝试"next“服务器，例如：
return httpClient.sendAsync(request,
HttpResponse.BodyHandlers.ofByteArray()
).thenCompose(response -> {
if (response.statusCode() == 200) {
浏览 2提问于2021-12-18得票数 2
2回答
Idea
我有一种处理方法，它接收项目列表并使用外部web服务异步处理它们。处理步骤还在处理过程中持久化数据。在整个过程结束时，我想坚持整个过程以及每一个处理结果。
问题
我将列表中的每个项目转换为CompletableFuture，并对它们运行一个处理任务，并将它们放回一个未来数组中。现在使用它的.ofAll方法(按顺序排列的方法)在所有提交的任务完成后完成将来，并返回另一个保存结果的CompletableFuture。
当我想获得这个结果时，我调用.whenComplete(..)，并希望将返回的结果设置为数据，然后持久化到数据库，但是存储库保存调用只是什么都不做，并且继续线程只是继续运行
浏览 7提问于2016-02-25得票数 10
考虑以下代码
public class TestCompletableFuture {
BiConsumer<Integer, Throwable> biConsumer = (x,y) -> {
System.out.println(x);
System.out.println(y);
};
public static void main(String args[]) {
TestCompletableFuture testF = new TestCompletableFuture();
浏览 2提问于2015-03-10得票数 8
有人知道如何将java CompletableFuture的whenComplete方法转换为Scala吗？我真的不知道该怎么做，我有点被困住了。谢谢
浏览 0提问于2018-10-10得票数 3
回答已采纳
我刚刚意识到，在可完成的未来，whenComplete内部的异常不会被记录/抛出。有人能解释一下吗？如何正确使用whenComplete？
public static void main(String[] args) {
var c = CompletableFuture.runAsync(() -> {
System.out.println("done");
});
c.whenComplete((unused, throwable) -> {
System.out.println((5/0));
浏览 2提问于2022-08-04得票数 1
回答已采纳
我试图想出一个CompletableFuture，它具有whenComplete和thenCompose的综合效果，特别是：
返回一个CompletionStage，而不仅仅是一个结果，类似于thenCompose。
即使在前一阶段异常完成时也会执行，类似于whenComplete，并且不会停止异常的传播。
接近我想要实现的目标，但我不想使用隐藏异常的handle。谢谢你的建议。
浏览 1提问于2019-06-19得票数 7
回答已采纳
Javadoc声明：
..。如果一个阶段的计算由于一个(未检查的)异常或错误而突然终止，那么所有需要完成它的依赖阶段也会异常地完成，而CompletionException将异常作为其原因。
作为异常完成，总是在CompletionException中包装异常为什么exceptionally()、whenComplete()和handle()将异常表示为Throwable而不是CompletionException
这很重要，因为它可以防止在这些方法中直接重新抛出异常。
这些方法是否有可能接收到CompletionException**？以外的异常？或者我能安全地强制使用这种类型的石
浏览 0提问于2018-03-12得票数 25
回答已采纳
我正在使用scala代码中的一个java库，它返回一个CompletableFuture。
我必须将其转换为TwitterFuture
当然，我可以将CompletableFuture转换为ScalaFuture，然后将ScalaFuture转换为TwitterFuture。但这是一种浪费。
我可以直接将CompletableFuture转换为TwitterFuture吗？
浏览 9提问于2018-01-02得票数 0
回答已采纳
我有以下代码(由产生)，它在远程服务器上调度任务，然后轮询是否使用ScheduledExecutorService#scheduleAtFixedRate完成任务。一旦任务完成，它就会下载结果。我希望将一个Future返回给调用者，这样他们就可以决定阻塞的时间和时间，并给他们取消任务的选项。
我的问题是，如果客户端取消了download方法返回的download，那么whenComplete块就不会执行。如果我删除thenApply，它就会删除。很明显我误解了Future的构图.我该换什么？
public Future<Object> download(Something some
浏览 2提问于2016-10-26得票数 10
回答已采纳
我有一个异步服务调用链，我想取消它。实际上，我有两个服务链并行进行，如果其中一个成功了，我想取消另一个。
对于番石榴的期货，我习惯于通过取消最后一个期货来取消整个期货链。看来我不能用java-8的未来来做这件事。，除非有人对方法有很好的了解。
如果您选择接受，就是告诉我是否可以保留我漂亮的语法并取消链式。否则，我将编写自己的链接，未来的包装-特别是在之后。
接下来是我自己的测试和尝试。
@Test
public void shouldCancelOtherFutures() {
// guava
ListenableFuture<String> as = Futu
浏览 2提问于2014-08-21得票数 10
回答已采纳
3回答
我试图按计划在Spring中每5分钟运行一次异步方法，使用每次运行的100 threads.At结束来处理1000个任务，我需要知道有多少任务失败了&成功了。我尝试使用可完成的未来使用下面的示例代码，但我面临两个主要问题。
如果出现一些异常，则按计划重新启动而不完成运行。
如何在运行后获得成功/失败任务编号我想在最后打印成功任务:1、2、4、5失败任务:9、10、7、8
//ScheduledTask
public void processTask(){
List<CompletableFuture<Integer>> futures=new A
浏览 2提问于2022-03-15得票数 2
回答已采纳
我想模拟一下，当CompletableFuture成功完成时，会调用一些代码。
我有这样一门课：
public class MyClassImplementRunner implements Runnable {
private final String param1;
public MyClassImplementRunner(String param1) {
this.param1 = param1;
}
public static CompletableFuture<Void> startAsync(String para
浏览 0提问于2018-10-27得票数 4
我希望在另一个CompletableFuture (在本例中是clonedWorld)中获得一个值，并返回这个未来。这是我的密码，我被困在这里：
@Override
public CompletableFuture<SlimeWorld> asyncCloneWorld(String worldName, String newWorld) {
loadWorldAsync(worldName).whenComplete((slimeWorld, throwable) -> {
if (throwable != null || slimeWorld.is
浏览 12提问于2021-12-27得票数 0
回答已采纳
1回答
我知道来自get()的CompletableFuture方法阻塞线程，但是在Future处理过程中如何实现执行System.out.println("xD")，因为现在这个语句是在CompletableFuture完成时执行的。
import java.util.concurrent.*;
import java.util.stream.Stream;
public class CompletableFutureTest {
public static void main(String[] args) throws ExecutionException, Inte
浏览 3提问于2017-11-29得票数 2
回答已采纳
我对Java的CompletableFuture相对缺乏经验，我可能需要一些帮助。这就是我想要做的。
/* I want to use the result of the future in a second one.
* So basically, what I want to do is to return the second future,
* but I don't want to block and wait for the first future to complete.
* /
CompletableFuture<TypeA> -> Compl
浏览 6提问于2019-01-29得票数 1
我有以下要求。
CreateDocument
对于文档，创建许多发行说明(releaseNotesFuture)
对于文档，创建许多包(parcelsFuture)
返回在1中创建的文档的objectId。
这是我目前的代码：
public CompletableFuture<ObjectId> createDeliveryNoteDocument(String productId, List<String> releaseNotesIds) {
CompletableFuture<ObjectId> delivery
浏览 0提问于2017-06-22得票数 4
回答已采纳
我正在尝试编写一系列步骤，以便通过创建以如下方式返回CompletableFuture<Boolean>的方法来避免if和else调用的大型嵌套链。
client.connect(identifier).thenCompose(b -> client.authenticate())
.thenCompose(b -> client.sendSetting(settings))
.thenCompose(b -> client.saveSettings())
浏览 10提问于2018-09-01得票数 1
示例1：
CometableFuture
.supplyAsync(new MySupplier())
.someCompletableFutureMethod(new SomeCompletableFutureComsumer())
ForkJoin线程是否曾经被阻塞过？
示例2：
final CompletableFuture cf = new CompletableFuture();
cf = executor.execute(new Runnable(){
public void run(){
//do work
cf.compl
浏览 3提问于2017-06-28得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
