前言:
大家是否熟悉FutureTask呢?或者说你有没有异步计算的需求呢?FutureTask就能够很好的帮助你实现异步计算,并且可以实现同步获取异步任务的计算结果。下面我们就一起从源码分析一下FutureTask。
了解一下什么是FutureTask?FutureTask 是一个可取消的异步计算。
FutureTask提供了对Future的基本实现,可以调用方法去开始和取消一个计算,可以查询计算是否完成,并且获取计算结果。
FutureTask只能在计算完成后获取到计算结果,一旦计算完成,将不能重启或者取消,除非调用runAndReset方法。
FutureTask除了实现了Future接口以外,还实现了Runnable接口,因此FutureTask是可以交由线程池的Executor执行,也可以直接使用一个异步线程调用执行(futureTask.run())。
FutureTask 是如何实现的呢?首先,我们看一下FutureTask类的继承结构,如下图,它实现的是RunnableFuture接口,而RunnableFuture继承自Future和函数式接口Runnable,所以说FutureTask本质就是一个可运行的Future。
Future 接口约定了一些异步计算类必须要实现的功能,源码如下:
Runnable 接口我们都很熟悉,他就是一个函数式接口,我们常用其创建一个线程。
FutureTask就是一个将要被执行的任务,它包含了以上接口具体的实现,FutureTask内部定义了任务的状态state和一些状态的常量,它的内部核心是一个Callable callable,我们通过构造函数可以传入callable或者是runnable,最后都会内部转为callable,因为我们需要获取异步任务的执行结果,只有通过Callable创建的线程才会返回结果。
我们可以通过此时的状态判断Future中isCancelled(),isDone()的返回结果。
以下为FutureTask源码,内含核心源码分析注释
FutureTask 运行流程一般来说,我们可以认为FutureTask具有以下三种状态:
未启动:新建的FutureTask,在run()没执行之前,FutureTask处于未启动状态。
已启动:FutureTask对象的run方法启动并执行的过程中,FutureTask处于已启动状态。
已完成:FutureTask正常执行结束,或者FutureTask执行被取消(FutureTask对象cancel方法),或者FutureTask对象run方法执行抛出异常而导致中断而结束,FutureTask都处于已完成状态。
FutureTask 的使用使用一(直接新建一个线程调用):
使用二(结合线程池使用)
到此这篇关于Java从源码看异步任务计算FutureTask的文章就介绍到这了,更多相关Java FutureTask内容请搜索七叶笔记以前的文章或继续浏览下面的相关文章希望大家以后多多支持七叶笔记!