源码分析: JDK Future模式分析
[TOC]
一.基本概念
基本方法接口
- Executor接口:
void execute(Runnable command)方法。开启一个线程执行任务,无返回值 - ExecutorService接口:
继承自Executor接口,里面的submit方法,最终会开启一个线程执行任务,并返回Future对象,该对象中含有该线程的返回值 - Callable接口可用于创建线程,call方法会有返回值且可抛出异常
基本示意图
二.源码分析
线程通过submit提交,该线程的返回值是怎么放到Future中的?
1. submit源码 — 摘自ExecutorService的实现类AbstractExecutorService(子类有ThreadPoolExecutor)
1 | public Future<?> submit(Runnable task) { |
都调用了newTaskFor方法,task任务作为参数传入。使用前面提到的execute执行开启一个新的线程,直接返回newTaskFor方法返回的RunnableFuture
通过Future接口的get方法,可以获得真实数据。如果没有则阻塞,有则取出。看状态,第五步分析
2. newTaskFor方法
1 | protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) { |
这里都调用了FutureTask的不同参数的构造方法。即每个newTaskFor方法得到的RunnableFuture接口的类型为FutureTask实现类
3. FutureTask的构造方法
1 | public FutureTask(Runnable runnable, V result) { |
- FutureTask中含有Callable类型的属性
- 以Runnable接口为参数的构造方法,调用了callable方法。该方法源码已贴,即使用了适配器模式,将Runnable接口适配成Callable接口类型(即call方法调用run,且无返回值)。放入到FutureTask的Callable属性
- 以Callable接口为参数的构造方法,直接放入到FutureTask的Callable属性
4. FutureTask的run方法。看完1-3,此时构造FutureTask完毕(即封装原始task完毕),开始调用executor方法,以FutureTask作为任务参数,开启新线程执行其中的run方法
1 | public void run() { |
其中调用call方法即执行了原始的任务。其他代码即是封装处理的部分,将返回的参数信息放到Future的result中
5. Future的get方法。获得真实数据
1 | public V get() throws InterruptedException, ExecutionException { |