Java带返回值并发编程：如何避免future.get()阻塞主线程

你当前使用的原生Future接口本身不支持异步回调机制，现有代码里的isDone()轮询+get()调用本质仍然是阻塞调用线程，没有实现非阻塞效果。直接用JDK 8自带的CompletableFuture改造即可，不需要引入任何第三方依赖，完全匹配你的需求。

具体实现步骤 #

1. 先定义全局独立线程池，避免使用JDK默认的公共ForkJoinPool导致业务资源被公共任务抢占，毕设场景设置2-4个核心线程足够：

private final ExecutorService asyncExecutor = Executors.newFixedThreadPool(3);

2. 改造原有两个业务方法，返回值改为CompletableFuture<String>，把耗时逻辑放到异步线程中执行，绑定完成回调：

private CompletableFuture<String> triggerMessage(String messageTyp) {
    return CompletableFuture.supplyAsync(() -> {
        try {
            Future<String> originFuture = new communicator().TriggerMessageFuture(queue, centralSystem, messageTyp);
            return originFuture.get();
        } catch (Exception e) {
            throw new RuntimeException("TriggerMessage task execute failed", e);
        }
    }, asyncExecutor).whenComplete((result, throwable) -> {
        if (throwable != null) {
            System.out.println("[TriggerMessage] execute error: " + throwable.getMessage());
            return;
        }
        System.out.println("[TriggerMessage] finish, result: " + result);
        // 此处编写拿到返回结果后的后续业务处理逻辑
    });
}

private CompletableFuture<String> getMeterValue(String key) {
    return CompletableFuture.supplyAsync(() -> {
        try {
            Future<String> originFuture = new communicator().getMeterValueFuture(queue, centralSystem, key);
            return originFuture.get();
        } catch (Exception e) {
            throw new RuntimeException("getMeterValue task execute failed", e);
        }
    }, asyncExecutor).whenComplete((result, throwable) -> {
        if (throwable != null) {
            System.out.println("[getMeterValue] execute error: " + throwable.getMessage());
            return;
        }
        System.out.println("[getMeterValue] finish, result: " + result);
        // 此处编写拿到返回结果后的后续业务处理逻辑
    });
}

3. 主线程调用时，提交任务后会立刻返回，不会被1-5秒的耗时逻辑阻塞：

// 主线程逻辑
public void processBiz() {
    // 提交两个异步任务，方法会立刻返回，不会阻塞
    CompletableFuture<String> msgTask = triggerMessage("testType");
    CompletableFuture<String> meterTask = getMeterValue("testKey");

    System.out.println("Async tasks submitted, main thread continue to process other logic");
    // 此处可继续执行主线程其他逻辑，比如响应前端请求、处理其他事件等
    // 异步任务执行完成后，会自动触发whenComplete中绑定的回调逻辑处理结果，不需要主线程轮询等待
}

注意事项 #

• 禁止在非必要场景调用无超时参数的get()方法：只要调用该方法，当前线程就会阻塞等待结果，直接退化为原有同步逻辑，失去异步非阻塞的意义。
• 如果需要等待多个异步任务全部执行完成后再做统一处理，可以使用CompletableFuture.allOf(msgTask, meterTask).thenRun(() -> { 多任务结果汇总处理逻辑 })，该方法同样不会阻塞主线程。
• 程序退出前记得调用asyncExecutor.shutdown()回收线程池资源，避免进程无法正常退出。
• 原有代码中的while轮询逻辑完全冗余：轮询本质还是占用调用线程等待，和直接调用get()没有区别，还会额外增加最多500ms的结果返回延迟，没有任何价值。

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