java - 在 lambda 中设置 CompletableFuture 的值

Question

我有以下代码:

public CompletableFuture<Object> send(String message) {
    CompletableFuture<Object> response =  new CompletableFuture<>();
    KafkaProducerRecord<String, String> record = ...
    KafkaProducer producer = ...
    producer.write(record, done -> {
        if(done.succeeded()) {
            Object o = ...
            response.complete(...);
        }
        else {
            Object o = ...
            response.complete(...);
        }
    });

    return response;
}

问题是，当调用 response.complete() 并传递正确的值时，无论 done.succeeded() 是 true 还是 false，response .result 始终返回为 null。只有在返回之前在 lambda 表达式外部调用 response.complete() 时，才会设置 response.result。

在调用方法中我尝试了以下方法:

CompletableFuture<IResponse> resp = this.send(message);
try {
  System.out.println(resp.get());
} catch (InterruptedException | ExecutionException e) {
  e.printStackTrace();
}

但这只是挂起。将 CompletableFuture 包装在 Observable 中，然后在 Observable 上执行 subscribe() 时也是如此，如下所示:

Observable.fromFuture(this.send(message)).subscribe(i -> {});

谁能帮忙，谢谢。

Answer 1

response.result is always being returned as null

您是如何进入该领域的？它是一个内部字段，用于存储计算后的结果。

要获取结果，您需要调用 get() ，该调用将阻塞直到结果准备就绪，或者调用 isDone() 来检查结果是否准备就绪。