Callable

Callable表示一个计算任务
V call() throws Exception；
call方法：

Runnable

Future

Future代表着异步计算结果，Future中提供了一些列方法用来检查计算结果是否已经完成，还提供了同步等待任务执行完成的方法，以及获取计算结果的方法等。当计算结果完成时只能通过提供的get系列方法来获取结果，如果使用了不带超时时间的get方法则在计算结果完成前，调用线程会被一直阻塞。另外计算任务是可以使用cancle方法来取消的，但是一旦一个任务计算完成，则不能再被取消了。

get

get方法：获取计算结果，在计算结果完成前，调用线程会被一直阻塞。

如果在等待结果的过程中有其他线程取消了该任务，则调用线程抛出CancellationException异常；如果在等待结果的过程中有其他线程中断了该线程，则调用线程抛出InterruptedException异常；如果任务计算过程中抛出了异常，则调用线程会抛出ExecutionException异常。

get

支持超时的get方法：在计算结果完成前，调用线程会被阻塞（阻塞时间取决于设置的超时时间）。

相比get()方法多了超时时间，不同在于线程调用了该方法后在任务结果没有计算出来前调用线程不会一直被阻塞，而是会在等待timeout个unit单位的时间后抛出TimeoutException异常后返回。添加超时时间这避免了调用线程死等的情况，让调用线程可以及时释放。

cancel

cancel方法：取消计算任务，但是一旦一个任务计算完成，则不能再被取消了。

尝试取消任务的执行;如果当前任务已经完成或者任务已经被取消了，则尝试取消任务会失败；如果任务还没被执行时候，调用了取消任务，则任务将永远不会被执行；如果任务已经开始运行了，这时候取消任务，则参数mayInterruptIfRunning将决定是否要将正在执行任务的线程中断，如果为true则标识要中断，否则标识不中断；当调用取消任务后，在调用isDone()方法，后者会返回true，随后调用isCancelled()方法也会一直返回true；如果任务不能被取消，比如任务已经完成了，任务已经被取消了,该方法会返回false。

isCancelled

isCancelled方法：用来检查计算结果是否取消。

如果任务在被执行完毕前被取消了，则该方法返回true，否则返回false。

isDone

isDone方法：用来检查计算结果是否已经完成。

如果计算任务已经完成则返回true，否则返回false，需要注意的是任务完成是指任务正常完成了或者由于抛出异常而完成了或者任务被取消了。

RunnableFuture

代表了一个可被取消的异步计算任务，该接口继承了Future接口和Runnalbe接口

FutureTask

FutureTask代表了一个可被取消的异步计算任务，该类实现了Future接口，比如提供了启动和取消任务、查询任务是否完成、获取计算结果的接口。

FutureTask任务的结果只有当任务完成后才能获取，并且只能通过get系列方法获取，当结果还没出来时候，线程调用get系列方法会被阻塞；另外一旦任务被执行完成，任务不能被重启，除非运行时候使用了runAndReset方法；FutureTask中的任务可以是Callable类型，也可以是Runnable类型（因为FutureTask实现了Runnable接口），FutureTask类型的任务可以被提交到线程池执行。

FutureTask实现了Future接口的所有方法，并且实现了Runnable接口，所以其是可执行任务，可以投递到线程池或者线程来执行。

state

FutureTask中变量state是一个使用volatile关键字修饰（用来解决多线程下内存不可见问题）的int类型，用来记录任务状态，任务状态枚举值如下：

一开始任务状态会被初始化为NEW；当通过set、 setException、 cancel函数设置任务结果时候，任务会转换为终止状态；在任务完成过程中，设置任务状态会变为COMPLETING（当结果被使用set方法设置时候），也可能会经过INTERRUPTING状态（当使用cancel(true)方法取消任务并中断任务时候）；当任务被中断后，任务状态为INTERRUPTED；当任务被取消后，任务状态为CANCELLED；当任务正常终止时候，任务状态为NORMAL；当任务执行异常后，任务会变为EXCEPTIONAL状态。

另外在任务运行过程中，任务可能的状态转换路径如下:

• NEW -> COMPLETING -> NORMAL ：正常终止流程转换
• NEW -> COMPLETING -> EXCEPTIONAL：执行过程中发生异常流程转换
• NEW -> CANCELLED：任务还没开始就被取消
• NEW -> INTERRUPTING -> INTERRUPTED：任务被中断

从上述转换可知，任务最终只有四种终态：NORMAL、EXCEPTIONAL、CANCELLED、INTERRUPTED，另外可知任务的状态值是从上到下递增的。

callable

callable是有返回值的可执行任务，创建FutureTask对象时候，可以通过构造函数传递该任务。

outcome

outcome是任务运行的结果，可以通过get系列方法来获取该结果,另外outcome这里没有被修饰为volatile，是因为变量state已经被使用volatile修饰了，这里是借用volatile的内存语义来保证写入outcome时候会把值刷新到主内存，读取时候会从主内存读取，从而避免多线程下内存不可见问题（可以参考《Java并发编程之美》一书）。

runner

runner变量，记录了运行该任务的线程，这个是在FutureTask的run方法内使用CAS函数设置的。

waiters

waiters变量是一个WaitNode节点，使用Treiber stack实现的无锁栈，栈顶元素就是使用waiters代表，栈用来记录所有等待任务结果的线程节点

WaitNode

WaitNode是一个简单的链表，用来记录所有等待结果而被阻塞的线程。

构造方法

构造函数内保存了传递的callable任务到callable变量，并且设置任务状态为NEW，这里由于state为volatile修饰，所以写入state的值可以保证callable的写入也会被刷入主内存，这避免了多线程下内存不可见性。

另外还有一个构造函数：

该函数传入一个Runnable类型的任务，由于该任务是不具有返回值的，所以这里使用Executors.callable方法进行适配，适配为Callable类型的任务.

Executors.callable(runnable, result)把Runnable类型的任务转换为了callable：

run() 方法

该方法是任务的执行体，线程是调用该方法来具体运行任务的，如果任务没有被取消，则该方法会运行任务，并且设置结果到outcome变量里面。

1. 如果任务不是初始化的NEW状态，或者使用CAS设置runner为当前线程失败，则直接返回；这个可以防止同一个FutureTask对象被提交给多个线程来执行，导致run方法被多个线程同时执行造成混乱。
2. 如果任务不为null，并且任务状态为NEW，则执行任务，其中代码2.1调用c.call()具体执行任务，如果任务执行OK，则调用set方法把结果记录到result,并设置ran为true；否则执行任务过程中抛出异常则设置result为null，ran为false，并且调用setException设置异常信息后，任务就处于终止状态，其中setException代码如下：

finishCompletion代码如下：

当任务已经处于终态后，激活waiters链表中所有由于等待获取结果而被阻塞的线程，并从waiters链表中移除他们，等所有由于等待该任务结果的线程被唤醒后，调用done（）方法，done默认实现为空实现。

当任务是正常执行完毕后set(result)的实现：

使用CAS尝试设置任务状态state为COMPLETING，如果CAS成功则把任务结果设置到outcome变量，并且设置任务状态为NORMAL终止状态，然后调用finishCompletion唤醒所有因为等待结果而被阻塞的线程。

get()方法

等待异步计算任务完成，并返回结果；

• 如果当前任务计算还没完成则会阻塞调用线程直到任务完成；
• 如果在等待结果的过程中有其他线程取消了该任务，则调用线程会抛出CancellationException异常；
• 如果在等待结果的过程中有线程中断了该线程，则抛出InterruptedException异常；
• 如果任务计算过程中抛出了异常，则会抛出ExecutionException异常。

1. 获取任务的状态，如果任务状态的值小于等于COMPLETING则说明任务还没有被完成，所以调用awaitDone挂起调用线程。
2. 如果任务已经被完成，则返回结果

• 如上代码1.1获取设置的超时时间，如果传递的timed为false说明没有设置超时时间，则deadline设置为0
• 代码1.2无限循环等待任务完成，其中代码1.2.1如果发现当前线程被中断则从等待链表中移除当前线程对应的节点（如果队列里面有该节点的话），然后抛出InterruptedException异常；代码1.2.2如果发现当前任务状态大于COMPLETING说明任务已经进入了终态（可能是NORMAL、EXCEPTIONAL、CANCELLED、INTERRUPTED中的一种），则把执行任务的线程的引用设置为null，并且返回结果；
• 代码1.2.3如果当前任务状态为COMPLETING说明任务已经接近完成了，就差设置结果到outCome了，则这时候让当前线程放弃CPU执行，意在让任务执行线程获取到CPU然后让任务状态从COMPLETING转换到终态NORMAL，这样可以避免当前调用get系列的方法的线程被挂起，然后在被唤醒的开销；
• 代码1.2.4如果当前q为null，则创建一个与当前线程相关的节点，代码1.2.5如果当前线程对应节点还没放入到waiters管理的等待列表，则使用CAS操作放入；
• 代码1.2.6如果设置了超时时间则使用LockSupport.parkNanos(this, nanos)让当前线程挂起deadline时间，否则会调用 LockSupport.park(this);让线程一直挂起直到其他线程调用了unpark方法,并且以当前线程为参数（比如finishCompletion（）方法）。

总的来说，进入这个方法，通常会经历三轮循环

1. 第一轮for循环，执行的逻辑是 q == null, 这时候会新建一个节点 q, 第一轮循环结束。
2. 第二轮for循环，执行的逻辑是 !queue，这个时候会把第一轮循环中生成的节点的 next 指针指向waiters，然后CAS的把节点q 替换waiters, 也就是把新生成的节点添加到waiters 中的首节点。如果替换成功，queued=true。第二轮循环结束。
3. 第三轮for循环，进行阻塞等待。要么阻塞特定时间，要么一直阻塞知道被其他线程唤醒。

   cancel(boolean mayInterruptIfRunning)方法

   尝试取消任务的执行。

• 如果当前任务已经完成或者任务已经被取消了，则尝试取消任务会失败；
• 如果任务还没被执行时候，调用了取消任务，则任务将永远不会被执行；
• 如果任务已经开始运行了，这时候取消任务，则参数mayInterruptIfRunning将决定是否要将正在执行任务的线程中断，如果为true则标识要中断，否则标识不中断；

当调用取消任务后，再调用isDone()方法，后者会返回true，随后调用isCancelled()方法也会一直返回true；

如果任务不能被取消，比如任务已经完成了，任务已经被取消了，该方法会返回false。

cancel方法的代码如下：

• 如上代码1，如果任务状态为New则使用CAS设置任务状态为INTERRUPTING或者CANCELLED，如果mayInterruptIfRunning设置为了true则说明要中断正在执行任务的线程，则使用CAS设置任务状态为INTERRUPTING，否则设置为CANCELLED；如果CAS失败则直接返回false。
• 如果CAS成功，则说明当前任务状态已经为INTERRUPTING或者CANCELLED，如果mayInterruptIfRunning为true则中断执行任务的线程，然后设置任务状态为INTERRUPTED。
• 最后代码3移除并激活所有因为等待结果而被阻塞的线程。

另外我们可以使用isCancelled()方法判断一个任务是否被取消了，使用isDone()方法判断一个任务是否处于终态了。

总结

当我们创建一个FutureTask时候，其任务状态初始化为NEW，当我们把任务提交到线程或者线程池后，会有一个线程来执行该FutureTask任务，具体是调用其run方法来执行任务。在任务执行过程中，我们可以在其他线程调用FutureTask的get()方法来等待获取结果，如果当前任务还在执行，则调用get的线程会被阻塞然后放入FutureTask内的阻塞链表队列；多个线程可以同时调用get方法，这些线程可能都会被阻塞到了阻塞链表队列。当任务执行完毕后会把结果或者异常信息设置到outcome变量，然后会移除和唤醒FutureTask内的阻塞链表队列里面的线程节点，然后这些由于调用FutureTask的get方法而被阻塞的线程就会被激活。

FutureTask的局限性

FutureTask虽然提供了用来检查任务是否执行完成、等待任务执行结果、获取任务执行结果的方法，但是这些特色并不足以让我们写出简洁的并发代码。比如它并不能清楚的表达出多个FutureTask之间的关系，另外为了从Future获取结果，我们必须调用get()方法，而该方法还是会在任务执行完毕前阻塞调用线程的，这明显不是我们想要的。
我们真正要想要的是：

• 可以将两个或者多个异步计算结合在一起变成一个，这包含两个或者多个异步计算是相互独立的时候或者第二个异步计算依赖第一个异步计算结果的时候。
• 对反应式编程的支持，也就是当任务计算完成后能进行通知，并且可以以计算结果作为一个行为动作的参数进行下一步计算，而不是仅仅提供调用线程以阻塞的方式获取计算结果。
• 可以通过编程的方式手动设置（代码的方式）Future的结果；FutureTask则不可以让用户通过函数来设置其计算结果，而是其任务内部来进行设置。
• 可以等多个Future对应的计算结果都出来后做一些事情。

为了克服FutureTask的局限性，以及满足我们对异步编程的需要，JDK8中提供了CompletableFuture，CompletableFuture是一个可以通过编程方式显式的设置计算结果和状态以便让任务结束的Future,本书后面章节我们会具体讲解。

总结

《Java异步编程实战》一书是国内首本系统讲解Java异步编程的书籍，本书涵盖了Java中常见的异步编程场景：这包含单JVM内的异步编程、以及跨主机通过网络通讯的远程过程调用的异步调用与异步处理、Web请求的异步处理、以及常见的异步编程框架原理解析和golang语言内置的异步编程能力。

1. Java 并发编程实战
2. Java 并发编程的艺术
3. Java 并发编程之美
4. Java异步编程实战