FutureTask是Java中用于异步计算的类,实现Future和Runnable接口,可包装Callable或Runnable任务,支持异步执行、结果获取、任务取消及状态查询;通过get()获取结果(阻塞等待),get(timeout)设置超时,isDone()判断完成,isCancelled()判断取消,cancel(true)尝试中断运行;与线程或线程池结合使用,异常时get()抛出ExecutionException,其cause为原始异常,常用于需精确控制任务生命周期的场景。
FutureTask 是 Java 并发编程中一个重要的类,位于 java.util.concurrent 包下,它实现了 Future 和 Runnable 接口,表示一个可取消的异步计算任务。你可以通过 FutureTask 来启动一个后台任务,并在需要时获取其结果,或检查任务是否完成、取消任务等。
FutureTask 包装了一个 Callable 或 Runnable 对象,将其封装为一个可以被线程执行并能返回结果的任务。它的核心能力包括:
由于它实现了 Runnable 接口,因此可以提交给 Thread 或线程池执行;又因为实现了 Future 接口,所以能通过 get() 方法获取执行结果,若结果尚未准备好,调用 get() 会阻塞直到结果可用。
通常有两种方式创建 FutureTask:
// 方式一:使用 Callable在实际开发中,FutureTask 常与线程池配合使用:
ExecutorService executor = Executors.newFixedThreadPool(2);例如,你可以在用户操作超时时主动取消耗时任务:
if (!futureTask.isDone()) {
.cancel(true);如果任务在执行过程中抛出异常,FutureTask 会将异常包装后保留。当你调用 get() 时,会抛出 ExecutionException,原始异常作为其 cause。你需要通过 getCause() 获取真实异常:
try {注意:一旦 get() 抛出 ExecutionException,说明任务执行失败;而 CancellationException 则表示任务被取消。
基本上就这些。FutureTask 在需要精确控制任务生命周期或整合 Runnable/Callable 到自定义执行逻辑时非常有用,虽然现在更多被 CompletableFuture 取代,但在底层并发控制中仍具价值。