futuretask 本身不直接支持回调,但可通过包装 callable 显式调用回调、继承并重写 done() 方法触发回调,或结合 completablefuture 实现链式异步回调;需注意异常捕获、线程安全及回调唯一性。

FutureTask 本身不直接支持回调,但可以通过包装或结合其他机制实现异步回调处理。核心思路是:在 FutureTask 执行完成后主动触发回调逻辑,而不是等待调用 get() 阻塞获取结果。
利用 Runnable/Callable 包装 + 手动触发回调
FutureTask 构造时可传入 Callable 或 Runnable,我们可以在 Callable 的 call() 方法中执行完业务逻辑后,显式调用回调函数。
- 定义一个回调接口,如 Callback
,含 onSuccess(T result) 和 onError(Throwable t) 方法 - 创建 Callable 时持有该回调引用,在 call() 中 try-catch 执行实际任务,成功则调用 onSuccess,异常则调用 onError
- 将该 Callable 传给 FutureTask 构造器,再提交到线程池执行
继承 FutureTask 重写 done() 方法
FutureTask 提供 protected 方法 done(),在任务完成(无论成功、异常或取消)时被调用,这是实现回调最常用且推荐的方式。
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 继承 FutureTask
,在子类中保存回调对象(Callback ) - 重写 done():调用 get() 获取结果(此时不会阻塞),根据是否抛出 ExecutionException 决定走 success 还是 error 分支
- 注意:done() 在任务线程中执行,若需切换到主线程(如 Android UI 更新),需额外调度
结合 CompletableFuture 实现更自然的回调链
虽然问题聚焦 FutureTask,但实际开发中更推荐用 CompletableFuture —— 它原生支持 thenApply、whenComplete、handle 等回调方法,且兼容 Executor。
- 可通过 CompletableFuture.supplyAsync(supplier, executor) 启动异步任务,supplier 返回结果,自动支持链式回调
- 若必须用 FutureTask,可将其作为 CompletableFuture 的底层执行单元:new CompletableFuture().completeAsync(() -> { /* 执行 FutureTask.get() */ }, executor)
- CompletableFuture 的回调默认异步执行,线程可控,错误传播更清晰
避免常见陷阱
手动实现回调时容易忽略关键细节,导致回调丢失或线程问题。
- 不要在 done() 中直接调用 get() 而不捕获 ExecutionException —— 会把异常吞掉,回调无法触发
- FutureTask 的 run() 方法只执行一次,多次调用无效;确保回调逻辑只在 done() 中注册一次
- 回调中涉及共享状态时,注意线程安全 —— done() 在任务线程执行,非主线程
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










