如何从其他类查看Future方法的状态码并获取其内部映射数据

跨类获取Future状态码 #

• 所有主流语言的Future实现均默认暴露状态查询接口，你只需要在持有Future实例的类中对外暴露合法的访问入口即可，不要直接访问类内私有属性。
• 以Java CompletableFuture 为例，实现逻辑参考如下：

// 持有Future实例的业务类
public class DataProcessService {
    // 内部维护的Future实例，返回结果包含状态码和处理完成的映射数据
    private CompletableFuture<Map<String, Object>> dataFuture;

    public DataProcessService() {
        // 初始化异步任务
        dataFuture = CompletableFuture.supplyAsync(() -> {
            // 这里执行你的映射数据处理逻辑
            Map<String, Object> result = new HashMap<>();
            result.put("code", 200); // 状态码
            result.put("processedMap", Map.of("user1", "info1", "user2", "info2")); // 处理完成的映射数据
            return result;
        });
    }

    // 对外暴露Future状态查询方法
    public boolean isTaskDone() {
        return dataFuture.isDone();
    }

    // 对外暴露状态码获取方法
    public Integer getTaskStatusCode() {
        if (isTaskDone()) {
            try {
                return (Integer) dataFuture.get().get("code");
            } catch (Exception e) {
                // 异常处理逻辑，比如返回500
                return 500;
            }
        }
        // 任务未完成时可根据业务需求返回约定值或者抛出异常
        return null;
    }
}

• 外部类直接调用dataProcessService.getTaskStatusCode()即可获取状态码，无需感知Future内部实现逻辑。

已处理完成的映射数据跨类使用说明 #

完全可以跨类使用，只需要满足两个前提：

• 访问数据时Future已经执行完成，避免出现线程阻塞或者空值问题
• 持有Future的类对外暴露了合法的访问入口，多线程场景下建议返回不可变的数据副本，避免数据被意外修改导致线程安全问题

你可以在上述DataProcessService类中追加映射数据访问方法：

// 追加到DataProcessService类中
public Map<String, Object> getProcessedMapData() {
    if (!isTaskDone()) {
        throw new IllegalStateException("异步任务未完成，暂无法获取映射数据");
    }
    try {
        // 返回不可变副本，避免外部修改内部缓存数据
        return Collections.unmodifiableMap((Map<String, Object>) dataFuture.get().get("processedMap"));
    } catch (Exception e) {
        throw new RuntimeException("获取映射数据失败", e);
    }
}

注意：如果调用数据获取方法时Future还未完成，直接调用get()会阻塞当前线程。如果不需要阻塞等待，可使用带超时参数的get(long timeout, TimeUnit unit)方法，或者使用回调类API处理任务完成后的逻辑。

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