当前位置：首页 > news >正文

学习分享-FutureTask

news 2025/6/22 19:12:26

前言

今天再改简历的时候回顾了之前实习用到的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();}
}