17370845950

java异常编程FutureTask的介绍
FutureTask是Java中用于异步计算的类,实现Future和Runnable接口,可包装Callable或Runnable任务,支持异步执行、结果获取、任务取消及状态查询;通过get()获取结果(阻塞等待),get(timeout)设置超时,isDone()判断完成,isCancelled()判断取消,cancel(true)尝试中断运行;与线程或线程池结合使用,异常时get()抛出ExecutionException,其cause为原始异常,常用于需精确控制任务生命周期的场景。

FutureTask 是 Java 并发编程中一个重要的类,位于 java.util.concurrent 包下,它实现了 FutureRunnable 接口,表示一个可取消的异步计算任务。你可以通过 FutureTask 来启动一个后台任务,并在需要时获取其结果,或检查任务是否完成、取消任务等。

FutureTask 的基本作用

FutureTask 包装了一个 Callable 或 Runnable 对象,将其封装为一个可以被线程执行并能返回结果的任务。它的核心能力包括:

  • 异步执行任务,不阻塞主线程
  • 支持获取任务执行结果(get 方法)
  • 支持任务取消(cancel 方法)
  • 可查询任务状态:是否完成、是否被取消

由于它实现了 Runnable 接口,因此可以提交给 Thread 或线程池执行;又因为实现了 Future 接口,所以能通过 get() 方法获取执行结果,若结果尚未准备好,调用 get() 会阻塞直到结果可用。

创建和使用 FutureTask

通常有两种方式创建 FutureTask:

// 方式一:使用 Callable
Callable task = () -> {
  Thread.sleep(2000);
  return 42;
};
FutureTask futureTask = new FutureTask(task);
new Thread(futureTask).start();
Integer result = futureTask.get(); // 阻塞等待结果 // 方式二:使用 Runnable + 结果占位
Runnable task2 = () -> System.out.println("执行无返回值任务");
FutureTask futureTask2 = new FutureTask(task2, null);

在实际开发中,FutureTask 常与线程池配合使用:

ExecutorService executor = Executors.newFixedThreadPool(2);
FutureTask future = new FutureTask(() -> 100);
executor.submit(future);
System.out.println(future.get()); // 输出 100

常用方法说明

  • get():获取任务执行结果,如果任务未完成则阻塞
  • get(long timeout, TimeUnit unit):带超时的 get,避免无限等待
  • isDone():判断任务是否已完成(正常结束、异常或取消都算完成)
  • isCancelled():判断任务是否被取消
  • cancel(boolean mayInterruptIfRunning):尝试取消任务。参数 true 表示允许中断正在运行的线程

例如,你可以在用户操作超时时主动取消耗时任务:

if (!futureTask.isDone()) {
  futureTask.cancel(true);
}

异常处理机制

如果任务在执行过程中抛出异常,FutureTask 会将异常包装后保留。当你调用 get() 时,会抛出 ExecutionException,原始异常作为其 cause。你需要通过 getCause() 获取真实异常:

try {
  Integer result = futureTask.get();
} catch (ExecutionException e) {
  Throwable cause = e.getCause();
  if (cause instanceof RuntimeException) {
    // 处理业务异常
  }
}

注意:一旦 get() 抛出 ExecutionException,说明任务执行失败;而 CancellationException 则表示任务被取消。

基本上就这些。FutureTask 在需要精确控制任务生命周期或整合 Runnable/Callable 到自定义执行逻辑时非常有用,虽然现在更多被 CompletableFuture 取代,但在底层并发控制中仍具价值。