在Java中如何实现异步回调机制
答案：Java中异步回调可通过接口回调、Future、CompletableFuture和线程池实现；定义AsyncCallback接口并在异步线程中调用onSuccess/onError完成通知；使用CompletableFuture可实现链式调用与异常处理；结合ExecutorService提升资源利用率；CompletableFuture支持任务编排，适用于复杂流程。
在Java中实现异步回调机制，核心是让耗时操作不阻塞主线程，同时能在任务完成后通知调用方。常用方式包括使用接口回调、Future、CompletableFuture 和线程池配合。下面介绍几种典型实现方式。
使用接口定义回调
通过自定义回调接口，在异步任务完成时触发回调方法。
定义一个回调接口：
interface AsyncCallback {void onSuccess(String result);
void onError(Exception e);
}
异步执行任务并回调：
void asyncTask(AsyncCallback callback) {new Thread(() -> {
try {
Thread.sleep(2000);
callback.onSuccess("任务完成");
} catch (Exception e) {
callback.onError(e);
}
}).start();
}
调用示例：
asyncTask(new AsyncCallback() {public void onSuccess(String result) {
System.out.println(result);
}
public void onError(Exception e) {
e.printStackTrace();
}
});
使用 CompletableFuture 实现链式回调
CompletableFuture 是 Java 8 引入的更强大的异步编程工具，支持链
式调用和组合操作。
try {
Thread.sleep(2000);
return "异步结果";
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException(e);
}
});
注册回调处理结果：
future.thenAccept(result -> {System.out.println("收到结果: " + result);
});
也可以处理异常：
future.exceptionally(throwable -> {System.err.println("发生错误: " + throwable.getMessage());
return null;
});
结合线程池提升资源利用率
手动创建线程不够高效，建议使用线程池管理异步任务。
ExecutorService executor = Executors.newFixedThreadPool(4);将任务提交到线程池：
CompletableFuturereturn "处理完成";
}, executor);
记得在程序结束前关闭线程池：
executor.shutdown();CompletableFuture 还支持多个异步任务的编排，比如 thenCombine、allOf 等方法，适合复杂场景。
基本上就这些。接口回调适合简单场景，CompletableFuture 更适合复杂的异步流程控制。关键是避免阻塞主线程，合理管理线程资源。
