Java Future源码分析

JDK future框架，提供了一种异步编程模式，基于线程池的。将任务runnable/callable提交到线程池executor，返回一个Future对象。通过future.get()获取执行结果，这里提交到线程池，后面的操作不会阻塞。future.get()获取结果会阻塞，其实也是用多线线程执行任务。

future.get()这里会阻塞，google的guava提供了一个calllback解决办法，这也是我准备看的

下面是一个future的demo

demo里面提交了一个Callable和一个Runnable到线程池，通过future获取计算结果

executorService.submit(callable)源码

这里主要是封装了一个RunnableFuture和提交任务到线程池

我们看下RunnableFuture里面的run方法，因为线程池执行任务，是执行run方法。看FutureTask里面的run方法

首先，设置runner为线程池中的当前线程，后面执行call()方法，计算出结果，set(result)。跟进set(result)

这里用了一个cas设置FutureTask的state字段为COMPLETING，完成中的一个状态。接着设置outcom为计算结果，我们跟进finishCompletion()

WaitNode主要是一个阻塞线程链表，即调用future.get()方法的线程链表。这里主要作用是注意唤醒这些线程，通过LockSupport.unpark(t)唤醒。这里用阻塞线程链表，主要是考虑到可能有多个线程会调用future.get()阻塞

ok,到这里执行任务，把计算结果放到future中，并唤醒阻塞线程已经理清楚了

我们再来看下，future.get()是如何实现阻塞，和获取到计算结果的

进入future.get()

Future.java是一个接口，这里看注释可以看出，会阻塞等待结果计算完成。我们看下一个实现FutureTask.java的get()方法

awaitDone(false, 0l)主要是阻塞线程，进入方法

这里，主要是阻塞线程，把当前线程放到阻塞线程链表中，通过LockSupport.park(this)阻塞当前线程，等待线程池里面的线程唤醒。唤醒之后，回到get()方法，看report()方法

这里主要是返回计算结果给阻塞线程

到这里，基本理清楚了，future的阻塞实现，以及获取计算结果的步骤。

future框架 = 线程池 + futrue