Java并发编程：深入理解FutureTask

"简谈java并发FutureTask的实现" 在Java并发编程中，FutureTask是一个重要的工具类，它结合了Runnable接口和Future接口的功能，允许我们异步执行任务并获取其结果。本文将深入探讨FutureTask的实现及其使用方式。 FutureTask概述 FutureTask是Java并发包`java.util.concurrent`中的一个类，它实现了Runnable接口，这意味着你可以将其提交给ExecutorService执行，同时也实现了Future接口，提供了一种机制来检查任务是否完成、取消任务以及获取或等待任务的结果。 主要方法 1. `isCancelled()`: 检查任务是否被取消。如果任务已经完成（无论正常完成还是被取消），则返回false；否则，如果任务已被取消，则返回true。 2. `isDone()`: 检查任务是否已经完成，包括正常完成、异常完成和被取消。 3. `cancel()`: 尝试取消任务的执行。如果任务尚未开始，或者在调用cancel()时任务正运行但能够响应中断，则任务会被取消。返回值表示是否成功取消。 4. `get()`: 阻塞并等待任务完成，然后返回结果。如果任务被取消，会抛出CancellationException；如果任务执行过程中发生异常，会抛出ExecutionException。 5. `get(long timeout, TimeUnit unit)`: 与`get()`类似，但会等待指定的最大时间，超时后仍未完成则抛出TimeoutException。 FutureTask的工作原理 尽管Runnable的run()方法不返回结果，FutureTask通过包装Callable来解决这个问题。当你创建一个FutureTask并传入一个Callable时，FutureTask会将Callable的结果存储在内部状态中。当FutureTask的run()方法被调用时，它实际上是在执行Callable的call()方法，并捕获call()的返回值和任何异常。这些信息随后可以在get()方法中获取。 使用示例 ```java public class FutureTaskTest { private static ExecutorService executorService = Executors.newFixedThreadPool(1); public static void main(String[] args) throws InterruptedException, ExecutionException { Callable<Integer> callable = new AccCallable(1, 2); FutureTask<Integer> futureTask = new FutureTask<>(callable); // 提交FutureTask到ExecutorService executorService.execute(futureTask); // 主线程继续执行其他业务 // ... // 在合适的时间点获取结果 int result = futureTask.get(); // 这里会阻塞直到任务完成 System.out.println("Result: " + result); // 关闭ExecutorService executorService.shutdown(); } } class AccCallable implements Callable<Integer> { private int a, b; public AccCallable(int a, int b) { this.a = a; this.b = b; } @Override public Integer call() { return a + b; } } ``` 在这个示例中，AccCallable实现了Callable接口，返回两个整数的和。FutureTask将这个Callable实例封装起来，并通过ExecutorService提交到线程池执行。主线程在适当时间调用`futureTask.get()`获取计算结果。 总结，FutureTask在Java并发编程中扮演着重要角色，它提供了一种在异步任务完成后获取结果的机制。了解FutureTask的工作原理和使用方式，有助于我们在设计高效的并发程序时更好地控制任务的执行和结果处理。