FutureTask源码解析一
FutureTask源码解析一
https://blog.csdn.net/jiangtianjiao/article/details/104029225
考虑到文章篇幅过长，分为两篇讲解
本片主要介绍FutureTask涉及的一些接口和基本知识
FutureTask简介
FutureTask是一种可取消的异步计算任务，它实现了Future接口，代表了异步任务的返回结果。从而FutureTask可以启动和取消异步计算任务、查询异步计算任务是否完成和获取异步计算任务的返回结果。只有异步计算任务结束时才能获取返回结果，当异步计算任务还未结束时调用get方法会使线程阻塞。一旦异步计算任务完成，计算任务不能重新启动或者取消，除非调用runAndReset。
FutureTask继承关系图
image-20210311194746175.png
FutureTask实现了RunnableFuture，RunnableFuture结合了Future和Runnable。
下面对上述接口进行逐个分析
①Runnable接口
@FunctionalInterface
public interface Runnable {
public abstract void run();
}
run方法定义了线程要执行的任务，但无返回值，那么需要返回值又该怎么办? 引入callable接口，callable能返回任务的执行结果。
②Callable接口
@FunctionalInterface
public interface Callable<V> {
V call() throws Exception;
}
相对于Runable，Callable具有返回值，可以向上抛出异常，而Runnable的run方法不能抛出异常，只能在方法内部进行catch处理。
③Future接口
Future接口用来代表一个异步操作的执行结果。我们可以用它来获取一个操作的执行结果、取消一个操作、判断一个操作是否已经完成或者是否被取消。
public interface Future<V> {
// 该方法用来获取执行结果, 如果任务还在执行中, 就阻塞等待
V get() throws InterruptedException, ExecutionException;
// 该方法同get方法类似, 不同的是它最多等待指定的时间, 如果指定时间内任务没有完成, 则会抛出TimeoutException异常;
V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException;
// 该方法用来尝试取消一个任务的执行, 它的返回值是boolean类型, 表示取消操作是否成功.
boolean cancel(boolean mayInterruptIfRunning);
// 该方法用于判断任务是否被取消了。如果一个任务在正常执行完成之前被cancel掉了, 则返回true
boolean isCancelled();
// 如果一个任务已经结束, 则返回true
// 任务结束包含了以下三种情况，见下面3）
boolean isDone();
}
根据FutureTask.run()方法被执行的时机，FutureTask可以处于下面3种状态
- ①未启动
FutureTask.run()方法还没有被执行之前，FutureTask处于未启动状态。
当创建一个FutureTask且没有执行FutureTask.run()方法之前，这个FutureTask处于未启动状态。 - ②已启动
FutureTask.run()方法被执行的过程中，FutureTask处于已启动状态。 - ③已完成
FutureTask.run()方法执行完后正常结束或被取消FutureTask.cancel(…)，或执行FutureTask.run()方法时抛出异常而结束，FutureTask处于已完成状态。
image-20210311194824489.png
当FutureTask处于未启动或已启动状态时，执行FutureTask.get()方法将导致调用线程阻塞。
当FutureTask处于已完成状态时，执行FutureTask.get()方法将导致调用线程立即返回结果或抛出异常。
当FutureTask处于未启动状态时，执行FutureTask.cancel()方法将导致此任务永远不会被执行。
当FutureTask处于已启动状态时，执行FutureTask.cancel(true)方法将以中断执行此任务线程的方式来试图停止任务。
注意：线程中断仅仅是置线程的中断状态位，并不会停止线程，需要用户自己去监视线程的状态为并做进一步处理。
当FutureTask处于已启动状态时，执行FutureTask.cancel(false)方法将不会对正在执行此任务的线程产生影响。
注意：此时会让正在执行的任务运行完成。
当FutureTask处于已完成状态时，执行FutureTask.cancel(...)方法将返回false。
image-20210311194851363.png
④RunnableFuture 接口
RunnableFuture接口同时继承了Runable与Callable接口
public interface RunnableFuture<V> extends Runnable, Future<V> {
void run();
}
FutureTask涉及工具类
①Executors
Executors是一个用于创建线程池的工厂类，同时提供了一些有用的静态方法，比如FutureTask中使用到的接口Executors.callable(runnable, result)，此处该类不是重点，不作过多解析，只简单描述与FutureTask相关部分。
public class Executors {
/**
* Returns a {@link Callable} object that, when
* called, runs the given task and returns the given result. This
* can be useful when applying methods requiring a
* {@code Callable} to an otherwise resultless action.
* @param task the task to run
* @param result the result to return
* @param <T> the type of the result
* @return a callable object
* @throws NullPointerException if task null
*/
public static <T> Callable<T> callable(Runnable task, T result) {
if (task == null)
throw new NullPointerException();
return new RunnableAdapter<T>(task, result);
}
/**
* A callable that runs given task and returns given result
*/
static final class RunnableAdapter<T> implements Callable<T> {
final Runnable task;
final T result;
RunnableAdapter(Runnable task, T result) {
this.task = task;
this.result = result;
}
public T call() {
task.run();
return result;
}
}
// RunnableAdapter采用了适配器模式，将一个Runnable类型对象适配成Callable类型。
// 对于result原样返回并无什么意义，只是适配成Callable需要返回值。
}
②Unsafe
Unsafe 是 sun.misc 包下的一个类，可以直接操作堆外内存，可以随意查看及修改JVM中运行时的数据，使Java语言拥有了类似C语言指针一样操作内存空间的能力。Unsafe 的操作粒度不是类，而是内存地址和所对应的数据，增强了Java语言操作底层资源的能力。后面单独写一篇关于Unsafe使用的文章，此处不是重点，不做解析。
