为何编译器提示无法将CompletableFuture<Object>转换为CompletableFuture<String>

类型报错的根因 #

你使用了错误的链式回调方法：thenApply仅适用于回调返回普通值的场景，当回调返回的是另一个CompletableFuture实例时，thenApply会返回嵌套的CompletableFuture<CompletableFuture<String>>，泛型推导时会向上擦除为Object，因此编译器判定返回类型不匹配。

你需要将loadFile1()后的thenApply替换为thenCompose，该方法专门用于处理回调返回CompletableFuture的场景，会自动扁平化嵌套的Future结构，直接返回CompletableFuture<String>符合你的预期。

修复后的基础写法如下：

import java.util.stream.Collectors;
import java.util.concurrent.CompletableFuture;

CompletableFuture<String> allGen = loadFile1().thenCompose(params1 -> {
    CompletableFuture<String> gen1 = loadFile2().thenApply(params2 -> 
        generateResultFile1(params1, params2)
    );
    CompletableFuture<String> gen2 = loadFile3().thenApply(params3 -> 
        generateResultFile2(params1, params3)
    );
    return CompletableFuture.allOf(gen1, gen2)
        .thenApply(r -> Stream.of(gen1, gen2)
            .map(CompletableFuture::join)
            .collect(Collectors.joining(","))
        );
});

更优的链式实现方式 #

针对只有两个并行任务的场景，你可以直接使用thenCombine简化逻辑，无需手动调用allOf和join，代码更简洁可读性更高：

import java.util.concurrent.CompletableFuture;

CompletableFuture<String> allGen = loadFile1().thenCompose(params1 -> 
    loadFile2().thenCombine(loadFile3(), 
        (params2, params3) -> String.join(",", 
            generateResultFile1(params1, params2),
            generateResultFile2(params1, params3)
        )
    )
);

该写法和原逻辑完全等价：拿到params1后会并行触发loadFile2和loadFile3，两个任务都完成后自动拼接结果返回，没有额外性能损耗。

如果后续需要扩展到3个及以上并行任务，原有的allOf + 流式join的写法就是最优选择，只需按需添加任务到allOf参数和流处理列表中即可。

内容的提问来源于stack exchange，提问作者Cristiano