java中通过future可获取异步任务结果，具体步骤为：1.创建executorservice线程池；2.使用submit()提交callable或runnable任务并返回future对象；3.调用future.get()获取结果，建议设置超时避免阻塞；4.通过future.cancel(true)取消任务。为避免get()阻塞，可采用设置超时时间、轮询isdone()或改用completablefuture。异常处理方面，executionexception包装任务异常，completablefuture提供exceptionally()等方法优雅处理。cancel(true)能否中断任务取决于任务实现，对阻塞操作有效，但无法强制停止纯计算任务，需在代码中主动检查中断状态。
使用Future可以在Java中获取异步任务的结果，它提供了一种非阻塞的方式来执行任务，并在稍后检索结果。核心在于提交任务到ExecutorService，然后通过返回的Future对象来获取结果。
解决方案
-
创建ExecutorService： 这是执行异步任务的线程池。
立即学习“Java免费学习笔记（深入）”；
ExecutorService executor = Executors.newFixedThreadPool(10);
-
提交任务： 使用
submit()方法提交Callable或Runnable任务。submit()返回一个Future对象。Future<String> future = executor.submit(new Callable<String>() { @Override public String call() throws Exception { // 模拟耗时操作 Thread.sleep(2000); return "任务完成！"; } }); -
获取结果： 使用
future.get()方法获取结果。get()方法会阻塞，直到结果可用。也可以设置超时时间，避免无限期阻塞。try { String result = future.get(3, TimeUnit.SECONDS); // 设置3秒超时 System.out.println("结果: " + result); } catch (InterruptedException e) { // 处理中断异常 e.printStackTrace(); } catch (ExecutionException e) { // 处理任务执行异常 e.printStackTrace(); } catch (TimeoutException e) { // 处理超时异常 System.out.println("任务超时！"); future.cancel(true); // 尝试取消任务 } finally { executor.shutdown(); // 关闭线程池 } 取消任务： 如果任务不再需要，可以使用
future.cancel()方法取消任务。cancel(true)会尝试中断正在执行的任务。
Future.get()阻塞问题如何避免？
Future.get()的阻塞特性确实是使用Future时需要特别注意的地方。如果不希望一直阻塞，可以采用以下策略：
设置超时时间： 如上面的例子所示，
future.get(timeout, TimeUnit)允许你指定一个超时时间。如果任务在指定时间内没有完成，会抛出TimeoutException，允许你进行相应的处理，比如取消任务。-
轮询检查
isDone()： 可以定期检查future.isDone()方法，该方法返回true如果任务已经完成、被取消或抛出异常。然后，只有当isDone()返回true时，才调用get()方法。虽然避免了无限期阻塞，但引入了轮询的开销。while (!future.isDone()) { try { Thread.sleep(100); // 短暂休眠，避免过度占用CPU } catch (InterruptedException e) { // 处理中断异常 e.printStackTrace(); } } try { String result = future.get(); System.out.println("结果: " + result); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } -
使用CompletableFuture：
CompletableFuture是Java 8引入的，是对Future的增强，提供了更强大的异步编程能力。它允许你注册回调函数，在任务完成时自动执行，而无需阻塞等待。CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> { try { Thread.sleep(2000); return "CompletableFuture 任务完成!"; } catch (InterruptedException e) { throw new RuntimeException(e); } }, executor); future.thenAccept(result -> { System.out.println("CompletableFuture 结果: " + result); }); // 注意：程序可能在任务完成前结束，需要保持executor运行
如何处理Future任务中的异常？
在异步任务中，异常处理尤为重要，因为异常可能发生在不同的线程中。
-
ExecutionException：
future.get()方法会抛出ExecutionException，它包装了异步任务中抛出的任何异常。你需要捕获ExecutionException并检查其内部的异常。try { String result = future.get(); } catch (ExecutionException e) { Throwable cause = e.getCause(); // 获取原始异常 if (cause instanceof MyCustomException) { // 处理自定义异常 } else { // 处理其他异常 cause.printStackTrace(); } } catch (InterruptedException e) { // 处理中断异常 } -
CompletableFuture的异常处理：
CompletableFuture提供了更优雅的异常处理方式，可以使用exceptionally()或handle()方法来处理异常。CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> { // 可能会抛出异常的代码 if (true) { throw new RuntimeException("模拟异常"); } return "任务完成"; }, executor); future.exceptionally(ex -> { System.err.println("发生异常: " + ex.getMessage()); return "默认值"; // 提供一个默认值 }).thenAccept(result -> { System.out.println("结果: " + result); // 即使发生异常，也会执行到这里 }); 在Callable内部处理： 也可以在
Callable的call()方法内部捕获并处理异常，然后返回一个表示错误状态的结果对象。
Future.cancel(true)真的能中断任务吗？
future.cancel(true)尝试中断任务，但其效果取决于任务的实现方式。
中断正在阻塞的线程： 如果任务在
Thread.sleep()、wait()或join()等方法上阻塞，cancel(true)会抛出InterruptedException，允许任务有机会清理资源并安全退出。-
无法中断非阻塞的计算： 如果任务在执行纯CPU计算，没有阻塞调用，
cancel(true)可能无法立即中断任务。在这种情况下，需要在任务代码中定期检查线程的中断状态（Thread.currentThread().isInterrupted()），并主动停止计算。Future<?> future = executor.submit(() -> { for (int i = 0; i < 1000000; i++) { // 模拟计算 double result = Math.sqrt(i); // 检查中断状态 if (Thread.currentThread().isInterrupted()) { System.out.println("任务被中断!"); return; // 退出任务 } } System.out.println("任务完成!"); }); // 在另一个线程中取消任务 new Thread(() -> { try { Thread.sleep(100); // 稍微等待 future.cancel(true); } catch (InterruptedException e) { e.printStackTrace(); } }).start();
总之，Future和CompletableFuture是Java中处理异步任务的重要工具。理解它们的特性和限制，并根据具体场景选择合适的策略，可以编写出更健壮、更高效的并发程序。
