java - CompletableFuture 包装器

Question

我有异步方法

asyncClass.getChild("test", listChild -> {
  if (listChild.isOk()) {
  List<String> list = listChild.isSuccess().getData()
  }
  return null;
});

如何在 CompletableFuture 中包装这个异步调用？

final CompletableFuture<List<String>> future = new CompletableFuture<>();
asyncClass.getChild("test", listChild -> {
  if (listChild.isOk()) {
    future.complete(listChild.isSuccess().getData());
  }
  return null;
});
return future;

一切正常，但我希望一切都在单独的线程调用中工作

interface AsyncFS {
    fun getChild(path: String, onResult: (Result<List<String>>) -> Unit)
}

Answer 1

似乎asyncClass.getChild异步执行(因为它需要回调)。如果是这种情况，那么您当前的实现就足够了(除了下面的更正)。

asyncClass.getChild("test", listChild -> {
  if (listChild.isOk()) {
    future.complete(listChild.isSuccess().getData());
  } else {
      future.complete(null); //you need to do this
      //or future.completeExceptionally(exception) if this is a failure
  }
});

如果你想要getChild在单独的线程中运行，那么我强烈建议您重新设计方法以使其返回 List<String>而不是回调。这种设计使得运行起来很尴尬getChild异步。

interface AsyncFS {
    fun getChild(path: String): List<String> //don't trust my syntax
}

然后以这种方式异步运行它:

CompletableFuture<List<String>> future = 
    CompletableFuture.supplyAsync(() -> asyncClass.getChild("test"));
return future;