前言
今天再改简历的时候回顾了之前实习用到的FutureTask，借此来回顾一下相关知识。
FutureTask 介绍
FutureTask 是 Java 并发包（java.util.concurrent）中的一个类，用于封装异步任务。它实现了 RunnableFuture 接口，而 RunnableFuture 接口继承了 Runnable 和 Future 接口。因此，FutureTask 既可以作为 Runnable 执行任务，也可以作为 Future 获取任务的结果。
主要功能
- 任务执行：可以通过线程池或单独的线程执行
FutureTask。 - 结果获取：可以通过
Future接口的get方法获取任务执行的结果。 - 任务取消：可以通过
Future接口的cancel方法取消任务的执行。 - 任务状态查询：可以查询任务是否已经完成、是否被取消等状态。
主要方法
run()：执行任务，当任务完成后设置其状态和结果。get()：等待任务执行完成，并返回结果。cancel(boolean mayInterruptIfRunning)：取消任务的执行。isDone()：检查任务是否已完成。isCancelled()：检查任务是否已被取消。
示例代码
以下是一个简单的 FutureTask 使用示例：
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;public class FutureTaskExample {public static void main(String[] args) {// 创建一个 Callable 任务，它返回一个字符串结果Callable<String> callableTask = () -> {Thread.sleep(2000);return "Task completed";};// 使用 FutureTask 封装 Callable 任务FutureTask<String> futureTask = new FutureTask<>(callableTask);// 创建一个单线程的线程池ExecutorService executorService = Executors.newSingleThreadExecutor();// 提交 FutureTask 给线程池执行executorService.submit(futureTask);// 主线程执行其他操作System.out.println("Main thread is doing other work...");try {// 获取 FutureTask 执行结果String result = futureTask.get();System.out.println("FutureTask result: " + result);} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}// 关闭线程池executorService.shutdown();}
}
解释
- 创建任务：定义一个
Callable任务，该任务会休眠 2 秒钟，然后返回字符串 “Task completed”。 - 封装任务：使用
FutureTask将Callable任务封装起来。FutureTask实际上就是一个可以异步执行的任务对象。 - 提交任务：将
FutureTask提交给线程池执行。线程池会管理任务的执行，并将执行结果存储在FutureTask中。 - 主线程工作：在任务执行期间，主线程可以继续执行其他操作，不会被阻塞。
- 获取结果：调用
FutureTask的get方法来获取任务的执行结果。如果任务还未完成，get方法会阻塞，直到任务完成并返回结果。 - 关闭线程池：任务完成后，关闭线程池，释放资源。
FutureTask 提供了一种将 Callable 或 Runnable 任务封装起来的机制，使得这些任务可以被异步执行，并且可以方便地获取任务的执行结果或取消任务。这使得编写并发程序更加简洁和高效。
