根据CompletableFuture的结果做一些事情，而不阻止Java中的线程

Question

首先，我不太熟悉CompletableFuture。我试图做的是通过CompletableFuture从数据库中检索数据，然后对结果进行处理。使用CompletableFuture#join/get处理数据会阻塞线程。

CompletableFuture<IPlayerData> future = playerDataManager.getOfflinePlayerDataAsync(target);
IPlayerData result = future.join(); //blocks the thread e.G. if database isn't reachable
//work with the result (maybe callback?)

请注意，我试图不在一个单独的线程上运行上面的代码部分。有没有什么好的办法来做到这个不堵？我很确定我的代码有问题（可能是GetOfflinePlayerAsync？）我真的不知道该怎么继续。

@Override
  public CompletableFuture<IPlayerData> getOfflinePlayerDataAsync(OfflinePlayer player) {
    CompletableFuture<IPlayerData> future = new CompletableFuture<>();
    DiscoBox.schedule(() -> future.complete(handler.loadObject(player.getUniqueId().toString()))).createAsyncTask(); //gets object from database
    return future;
  }

Answer 1

如果您不想阻止“接收”值的线程，您可以在以下情况下执行以下操作：

// Get the value if it is available
if (future.isDone()) {
     value = future.get();
     // do something with value
}

// Get the value if it is available in the next second
try {
    value = future.get(1, TimeUnit.SECONDS);
    // do something with  value
} catch (TimeoutException ex) {
    // ho hum
}

有了completablefuture，还有其他非阻塞的替代方案；例如。

value = future.getNow(someDefault);
if (value != someDefault) {
     // do something with value
}

注意，使用以上所有内容，您只尝试一次获取值。如果一次尝试还不够，你可能会想做这样的事情：

while (!future.isDone()) {
     // do something else
}
value = future.get();
// do something with value

但这可能会阻塞线程...实际上。在将来完成之前，您不能越过上面代码的结尾。

如果您不关心值何时可用，因为您不打算用它做任何事情，那么您可以简单地忽略future。

最后，异步传递值的另一种方法是使用回调。您可以提供一个回调函数作为GetOfflinePlayerDataAsync方法的参数。那么您可以提供如下结果：

    DiscoBox.schedule(() -> callback(handler.loadObject(...))).createAsyncTask();

回调可以简单地将返回的值赋给某个共享变量，也可以执行更复杂的操作。关键是它将在异步任务的线程上执行，而不是在调用GetOfflinePlayerDataAsync的线程上执行。