CompletableFuture与Future对比实现问题：正确获取Callable结果

问题根源 #

CompletableFuture.supplyAsync()接收的是Supplier<T>函数式接口，而你现有的GetSiteMeterTariffValues实现的是Callable<ArrayList<MeterTariffValues>>——两者核心差异在于Callable允许抛出受检异常，Supplier则不允许，直接适配会导致类型推断异常，无法正确识别返回类型。

解决方案 #

方案1：将Callable适配为Supplier（推荐）

手动捕获Callable的受检异常，用CompletionException包装后抛出，同时指定自定义TaskExecutor保持线程环境一致：

GetSiteMeterTariffValues task = new GetSiteMeterTariffValues();
CompletableFuture<ArrayList<MeterTariffValues>> future = CompletableFuture.supplyAsync(() -> {
    try {
        return task.call();
    } catch (Exception e) {
        throw new CompletionException(e); // 符合CompletableFuture异常处理规范
    }
}, taskExecutor);

// 与Future一致的结果获取逻辑
try {
    ArrayList<MeterTariffValues> result = future.get();
    // 业务处理逻辑
} catch (InterruptedException | ExecutionException e) {
    // 异常处理逻辑
}

方案2：手动绑定Callable与CompletableFuture

通过自定义任务执行逻辑，手动完成CompletableFuture的结果或异常：

GetSiteMeterTariffValues task = new GetSiteMeterTariffValues();
CompletableFuture<ArrayList<MeterTariffValues>> future = new CompletableFuture<>();

taskExecutor.execute(() -> {
    try {
        ArrayList<MeterTariffValues> result = task.call();
        future.complete(result);
    } catch (Exception e) {
        future.completeExceptionally(e);
    }
});

// 同样使用get()获取结果
ArrayList<MeterTariffValues> result = future.get();

关键注意点 #

• 明确指定CompletableFuture的泛型为ArrayList<MeterTariffValues>，避免类型推断模糊，这是解决类型识别问题的核心步骤之一。
• 若需保持与原Future一致的线程池行为，务必在supplyAsync()中传入自定义的TaskExecutor，否则会默认使用ForkJoinPool.commonPool()。

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