如何把 循环CompletableFuture<List<Map<String, Object>>>

转换为普通的 List<Map<String, Object>> 类型？

您可以使用 CompletableFuture 的 join 方法来等待 CompletableFuture 完成，然后将结果转换为 List<Map<String, Object>> 类型。示例如下：

CompletableFuture<List<Map<String, Object>>> future = // your CompletableFuture

List<Map<String, Object>> result = future.join();

请注意，join 方法会阻塞当前线程，直到 CompletableFuture 完成。如果 CompletableFuture 发生异常，则 join 方法会抛出该异常。因此，您可以使用 try-catch 块来处理异常。

相关问题

java for循环，循环外定义了两个数组对象 CompletableFuture<List<Map<String,Object>>>[] futuresDa = new CompletableFuture[floorIds.size()]; CompletableFuture<List<Map<String,Object>>>[] futuresXiao = new CompletableFuture[floorIds.size()]; 在for循环内 循环调用两个异步方法， 第一个异步方法返回：CompletableFuture<List<Map<String,Object>>> addDaXiang 执行完第一个异步方法 调用CompletableFuture.allOf(futuresDa).join(); CompletableFuture 空指针

根据你提供的信息，我猜测你的代码大致如下：

CompletableFuture<List<Map<String,Object>>>[] futuresDa = new CompletableFuture[floorIds.size()];
CompletableFuture<List<Map<String,Object>>>[] futuresXiao = new CompletableFuture[floorIds.size()];
for (int i = 0; i < floorIds.size(); i++) {
    CompletableFuture<List<Map<String,Object>>> addDaXiang = addDaXiang(floorIds.get(i));
    CompletableFuture<List<Map<String,Object>>> addXiaoXiang = addXiaoXiang(floorIds.get(i));
    futuresDa[i] = addDaXiang.thenApplyAsync(daXiang -> {
        // some code here
        return someValue;
    });
    futuresXiao[i] = addXiaoXiang.thenApplyAsync(xiaoXiang -> {
        // some code here
        return someValue;
    });
}
CompletableFuture.allOf(futuresDa).join();

根据代码分析，我认为你出现空指针异常的原因是因为`addDaXiang`方法返回的`CompletableFuture`对象为空。这可能是因为在异步方法内部出现异常，导致返回的`CompletableFuture`对象没有正确地被赋值。

你可以在`addDaXiang`方法内部添加异常处理逻辑，将异常信息打印出来，以便你更好地定位问题所在。例如：

public CompletableFuture<List<Map<String,Object>>> addDaXiang(int floorId) {
    CompletableFuture<List<Map<String,Object>>> future = new CompletableFuture<>();
    // some code here
    try {
        // some code here
        future.complete(someValue);
    } catch (Exception e) {
        future.completeExceptionally(e);
    }
    return future;
}

这样，如果`addDaXiang`方法内部出现异常，将会把异常信息放入`CompletableFuture`对象中，并返回给调用者。在调用者处，你可以通过`CompletableFuture.exceptionally()`方法来处理异常信息。

java for循环，循环外定义了两个数组对象 CompletableFuture<Integer>[] futuresDa = new CompletableFuture[floorIds.size()]; CompletableFuture<List<Map<String,Object>>>[] futuresXiao = new CompletableFuture[floorIds.size()]; 在for循环内 循环调用两个异步方法， 第一个异步方法返回：CompletableFuture<List<Map<String,Object>>> addDaXiang 执行完第一个异步方法 调用CompletableFuture.allOf(futuresDa).join(); CompletableFuture 空指针

根据你提供的信息，我猜测你的代码大致如下：

CompletableFuture<Integer>[] futuresDa = new CompletableFuture[floorIds.size()];
CompletableFuture<List<Map<String,Object>>>[] futuresXiao = new CompletableFuture[floorIds.size()];
for (int i = 0; i < floorIds.size(); i++) {
    CompletableFuture<List<Map<String,Object>>> addDaXiang = addDaXiang(floorIds.get(i));
    CompletableFuture<List<Map<String,Object>>> addXiaoXiang = addXiaoXiang(floorIds.get(i));
    futuresDa[i] = addDaXiang.thenApplyAsync(daXiang -> {
        // some code here
        return someValue;
    });
    futuresXiao[i] = addXiaoXiang.thenApplyAsync(xiaoXiang -> {
        // some code here
        return someValue;
    });
}
CompletableFuture.allOf(futuresDa).join();

根据代码分析，我认为你出现空指针异常的原因是因为`addDaXiang`方法返回的`CompletableFuture`对象为空。这可能是因为在异步方法内部出现了异常，导致返回的`CompletableFuture`对象没有正确地被赋值。

你可以在`addDaXiang`方法内部添加异常处理逻辑，将异常信息打印出来，以便你更好地定位问题所在。例如：

public CompletableFuture<List<Map<String,Object>>> addDaXiang(int floorId) {
    CompletableFuture<List<Map<String,Object>>> future = new CompletableFuture<>();
    // some code here
    try {
        // some code here
        future.complete(someValue);
    } catch (Exception e) {
        future.completeExceptionally(e);
    }
    return future;
}

这样，如果`addDaXiang`方法内部出现异常，将会把异常信息放入`CompletableFuture`对象中，并返回给调用者。在调用者处，你可以通过`CompletableFuture.exceptionally()`方法来处理异常信息。