如何处理JavaFutureTask的异常

在Java中，FutureTask是一个实现了RunnableFuture接口的类，用于表示异步计算的结果。处理FutureTask的异常主要有以下几种方法：

1. 在Callable任务中抛出异常：

   当你在实现Callable接口的任务中抛出异常时，这个异常将被传递到调用FutureTask.get()方法的线程中。调用get()方法时，线程会抛出ExecutionException，你可以通过调用ExecutionException.getCause()来获取原始异常。

   示例：

   FutureTask<Integer> futureTask = new FutureTask<>(new Callable<Integer>() {
       @Override
       public Integer call() throws Exception {
           // 抛出自定义异常
           throw new CustomException("An error occurred");
       }
   });
   
   // 提交任务并执行
   new Thread(futureTask).start();
   
   try {
       // 获取任务结果，将抛出ExecutionException
       Integer result = futureTask.get();
   } catch (InterruptedException e) {
       // 处理中断异常
   } catch (ExecutionException e) {
       // 获取原始异常
       Throwable cause = e.getCause();
       cause.printStackTrace();
   }
   

2. 使用FutureTask.get(long timeout, TimeUnit unit)方法：

   当你在调用get()方法时提供一个超时参数，如果任务在指定的时间内未完成，get()方法将抛出TimeoutException。在这种情况下，你无法直接从TimeoutException中获取原始异常。你需要在任务代码中处理异常，并将其包装在自定义异常中，然后在调用get()方法时捕获ExecutionException。

   示例：

   FutureTask<Integer> futureTask = new FutureTask<>(new Callable<Integer>() {
       @Override
       public Integer call() throws Exception {
           // 抛出自定义异常
           throw new CustomException("An error occurred");
       }
   });
   
   // 提交任务并执行
   new Thread(futureTask).start();
   
   try {
       // 获取任务结果，超时时间为1秒
       Integer result = futureTask.get(1, TimeUnit.SECONDS);
   } catch (InterruptedException e) {
       // 处理中断异常
   } catch (ExecutionException e) {
       // 获取原始异常
       Throwable cause = e.getCause();
       cause.printStackTrace();
   } catch (TimeoutException e) {
       // 处理超时异常
   }
   

总之，处理FutureTask的异常主要涉及到在任务代码中抛出异常以及在调用get()方法时捕获和处理ExecutionException。在实际应用中，你需要根据具体需求选择合适的方法来处理异常。