futuretask源码解读

作者：洛阳含义网

71人看过

发布时间：2026-03-19 20:17:11

标签：futuretask源码解读

未来任务（FutureTask）源码解读：从基础到深度剖析未来任务（FutureTask）是Java并发编程中一个非常重要的类，它封装了一个异步任务的执行结果，并提供了对任务状态的访问方式。无论是单线程还是多线程环境下，FutureT

未来任务（FutureTask）源码解读：从基础到深度剖析
未来任务（FutureTask）是Java并发编程中一个非常重要的类，它封装了一个异步任务的执行结果，并提供了对任务状态的访问方式。无论是单线程还是多线程环境下，FutureTask都扮演着关键的角色。这篇文章将从源码结构、执行流程、线程管理、异常处理等方面，深入解析FutureTask的实现原理与使用方法。
一、FutureTask的基本结构与实现
FutureTask是一个接口，它定义了任务执行后的结果获取方法。同时，它也是一个实现类，封装了任务的执行过程。FutureTask的结构主要由以下几个部分构成：
1. 任务状态：FutureTask通过`state`字段记录当前任务的状态，包括`NEW`（未执行）、`RUNNING`（正在运行）、`COMPLETING`（正在完成）、`COMPLETED`（已完成）等状态。
2. 任务执行逻辑：通过`call()`方法启动任务的执行，该方法内部调用了`doRun()`方法，负责执行任务逻辑。
3. 结果存储：`get()`方法用于获取任务结果，`get()`方法内部会调用`wait()`等待任务完成，并返回结果。
4. 线程管理：FutureTask内部通过`Thread`类管理执行线程，确保任务在指定的线程中运行。
FutureTask的源码结构如下：
java
public class FutureTask extends Object implements Runnable, Future
private volatile int state;
private volatile V result;
private volatile Thread thread;
private volatile boolean done;
private volatile boolean cancel;
private volatile boolean isCancelled;
private volatile boolean isDaemon;
private volatile boolean isInterrupted;
public FutureTask(Runnable task, V result)
this.task = task;
this.result = result;
this.state = NEW;

public FutureTask(Runnable task)
this.task = task;
this.state = NEW;

public FutureTask(Runnable task, V result, boolean cancel)
this.task = task;
this.result = result;
this.cancel = cancel;
this.state = NEW;

public void run()
if (state == NEW)
state = RUNNING;
try
// 执行任务逻辑
if (task != null)
task.run();

catch (Throwable e)
// 处理异常

state = COMPLETED;

public V get() throws InterruptedException
// 等待任务完成
while (state != COMPLETED)
wait();

return result;

public boolean cancel(boolean mayInterruptIfRunning)
if (state == NEW || state == COMPLETED)
return false;

if (mayInterruptIfRunning)
if (thread != null)
thread.interrupt();

state = CANCELLED;
return true;

public boolean isCancelled()
return state == CANCELLED;

public boolean isDone()
return state == COMPLETED || state == CANCELLED;

public V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException
// 等待任务完成
while (state != COMPLETED)
wait(unit.toMillis(timeout));

return result;

public boolean getNow(V value)
// 获取当前结果
if (state == COMPLETED)
return result;

return value;

public void interrupt()
if (state == RUNNING || state == COMPLETED)
thread.interrupt();

public void set(V result)
this.result = result;
state = COMPLETED;

public void setException(Throwable cause)
this.result = null;
this.state = COMPLETED;
if (cause != null)
throw new RuntimeException(cause);

public void setThrowException(Throwable cause)
this.result = null;
this.state = COMPLETED;
throw new RuntimeException(cause);

public static void main(String[] args)
FutureTask task = new FutureTask<>(() ->
return "Hello, World!";
);
Thread thread = new Thread(task);
thread.start();
try
System.out.println(task.get());
catch (Exception e)
e.printStackTrace();

二、FutureTask的执行流程
FutureTask的执行流程主要分为以下几个阶段：
1. 初始化阶段：创建FutureTask对象时，会根据传入的Runnable任务和结果初始化相关字段。
2. 启动任务：调用`run()`方法启动任务，该方法会将任务交给线程执行。
3. 任务执行：任务在指定线程中执行，期间可能会抛出异常，此时FutureTask会捕获异常并存储到`result`字段中。
4. 结果获取：调用`get()`方法获取任务结果，该方法会等待任务完成，确保结果被正确返回。
在执行过程中，FutureTask使用了`volatile`关键字来确保线程安全，同时通过`wait()`、`notify()`等方法实现线程间的同步，确保任务的正确执行。
三、线程管理与任务调度
FutureTask通过`Thread`类管理任务的执行线程，它支持多线程并发执行。当调用`start()`方法时，任务会被提交到线程池中执行，具体线程的选择取决于调用`start()`的调用者。
此外，FutureTask还支持任务的取消操作，通过`cancel()`方法可以中断正在运行的任务。如果任务尚未完成，`cancel()`方法会返回`true`，否则返回`false`。
四、异常处理机制
FutureTask在任务执行过程中可能会抛出异常，这些异常会被`setException()`方法捕获并存储在`result`字段中。当调用`get()`方法获取结果时，会检查`result`是否为`null`，如果为`null`则表示任务未完成或异常未被处理。
此外，`setException()`方法还支持传入`Throwable`对象，它会将异常作为任务结果返回，确保异常信息不会丢失。
五、任务状态管理
FutureTask通过`state`字段记录任务的执行状态。该字段的值包括以下几种：
- `NEW`：任务尚未开始执行。
- `RUNNING`：任务正在执行。
- `COMPLETING`：任务正在完成。
- `COMPLETED`：任务已完成。
- `CANCELLED`：任务被取消。
- ` INTERRUPTED`：任务被中断。
在任务执行过程中，`state`字段会根据任务的执行状态进行更新，确保线程安全。
六、使用FutureTask的注意事项
1. 线程安全：FutureTask内部使用了`volatile`关键字确保多线程环境下的线程安全。
2. 任务执行：任务执行由调用`start()`方法启动，不能直接调用`run()`方法。
3. 异常处理：任务执行过程中可能出现的异常，应通过`setException()`方法处理，避免抛出未捕获的异常。
4. 任务取消：可以通过`cancel()`方法取消任务，但任务未完成时，`cancel()`方法会返回`false`。
七、FutureTask的高级特性
1. 任务结果的缓存：FutureTask支持将任务结果缓存到`result`字段中，供后续调用`get()`方法使用。
2. 任务状态的同步：通过`wait()`、`notify()`等方法实现任务状态的同步，确保线程间的协调执行。
3. 任务的中断：支持中断任务的执行，确保任务在需要时能够被停止。
4. 任务的取消：支持任务的取消操作，确保任务在需要时能够被终止。
八、总结
FutureTask是Java并发编程中不可或缺的类，它封装了异步任务的执行过程，并提供了对任务状态的访问方式。无论是任务的启动、执行、完成，还是异常处理、取消操作，FutureTask均提供了完整的解决方案。通过深入理解FutureTask的源码结构和执行流程，开发者能够更加高效地编写并发程序，提高代码的可维护性和可扩展性。
在未来的发展中，FutureTask将继续扮演重要角色，支持更复杂的异步任务处理。通过合理使用FutureTask，开发者可以更好地应对多线程环境下的各种挑战，确保程序的稳定运行。

上一篇 : fuji调色解读

下一篇 : fxi全称解读