Java-Future学习

什么是Future?干什么的解决什么问题?在什么情况使用?

带着问题,我们去看看。

首先,Future对象是一个异步计算的结果,而在Callable任务中可以拿到这个Future的对象。那同样是run执行,为什么Runable没有这个对象?

         这还是一个设计思路的问题,google希望我们执行一个普通的任务的时候,大家都去用Runable就好了,执行完系统就帮你销毁了,而当我们需要得到一个Future的时候,意味着我们的使用场景不同了,我们需要他来帮我们分析任务在执行过程中出现了哪些状况。

也就是说Runable没必要有返回值,因为我已经有一个更适合的角色Future帮我去做这件事了,设计就是如此。


Future这个接口

interface Future<V>  泛型未知,需要我们传递一个指定的类型

看一下源码的注释

* @see FutureTask

 * @see Executor

 * @since 1.5 

* @author Doug Lea 

* @paramThe result type returned by this Future's {@code get} method

1.see 提示我们参考FutureTask 和 Executor

2.实现版本java1.5版本

3.分享者Doug Lea,对Java影响力最大的个人,util.concurrent包的来源

我们可以瞻仰一下Doug Lea作者,希望能早日 达到  接近大神


纽约州立大学Oswego分校计算机科学系的老大爷


再来看看concurrent包下的内容,难以想象人家的大脑到底装了些什么,没有对比就没有伤害。


大量有关线程池和队列的类


Future接口方法


boolean cancel(boolean mayInterruptIfRunning);

mayInterruptIfRunning参数的字面含义是“可能中断运行”,他有很多情况,为什么会有这么多种情况还要参见FutureTask中的定义

1.如果任务已经执行完毕,那么返回false。

2.如果任务已经取消,那么返回false。

3.如果任务已经停止,则cancel()方法会返回true。

4.mayInterruptIfRunning是否中断其运行,设置ture中断,否者任务将继续运行直到结束。

5.此方法返回后任务要么处于运行结束状态,要么处于取消状态。isDone()将永远返回true,如果cancel()方法返回true,isCancelled()始终返回true。


boolean isCancelled();

是否被取消,如果计算在正常结束前被取消了,则返回true


boolean isDone(); 

是否完成


V get() throws InterruptedException, ExecutionException;

返回结果,如果计算未完成,则等待任务完成,计算被取消抛的异常和执行时异常


V get(long timeout, TimeUnit unit)

throws InterruptedException, ExecutionException, TimeoutException;

设置一个等待时间,超时会抛异常,比上面的方法多出一个超时的异常。

总结一下就是:Future就是对Callable任务的执行结果进行取消、查询是否完成、获取结果、设置结果操作。get方法会阻塞,直到任务返回结果()为止。


FutureTask

Future主要通过FutureTask结合线程池来使用。FutureTask实现了RunnableFuture接口(1.6版本出现),而RunnableFuture又同时实现了Runnable和Future<V>接口,意味着可以交给Executor执行,这里很有趣的是,既然RunnableFuture是1.6才出来,换言之在1.5出现线程池的时候调用方式只能在FutureTask中通过.run()来运行。

我们先看看FutureTask中构造方法。

publicFutureTask(Runnable runnable,Vresult) {

this.callable= Executors.callable(runnable, result);

this.state=NEW;// ensure visibility of callable

}

初始化状态为NEW,下面是状态的设置0-6。

private volatile int state;

private static final int NEW          = 0;

private static final int COMPLETING  = 1;

private static final int NORMAL      = 2;

private static final int EXCEPTIONAL  = 3;

private static final int CANCELLED    = 4;

private static final int INTERRUPTING = 5;

private static final int INTERRUPTED  = 6;


run() 方法中执行成功调用set(状态),执行失败抛异常,如下。

if(c !=null&&state==NEW) {

Vresult;

booleanran;

try{

result = c.call();

ran =true;

}catch(Throwable ex) {

result =null;

ran =false;

setException(ex);

}

if (ran)

set(result);



set方法中把状态设置成COMPLETING 然后设置成NORMAL,换言之run()执行完毕状态都会改变,不再为NEW了,如下。

protected void set(Vv) {

if(UNSAFE.compareAndSwapInt(this,stateOffset,NEW,COMPLETING)) {

outcome= v;

UNSAFE.putOrderedInt(this,stateOffset,NORMAL);// final state

finishCompletion();

}

}


接着是cancel()方法中设为ture时把状态 NEW->INTERRUPTING ->INTERRUPTED,cancel()为false的状态变化就是NEW->=CANCELLED。

cancel()方法仅仅只是改变了futureTask的状态位并没有起到结束进程的作用,这是为什么呢?

我们看看future.get()方法可知,如果一个futureTask被cancel()了,调用get()方法会抛出CancellationException。也就是说cancel(true)方法也只是希望当前线程可以响应中断而已,当线程被阻塞,抛出InterruptedException。也就可以解释的通为什么future的方法

boolean cancel(boolean mayInterruptIfRunning)  中定义为什么取名为mayInterruptIfRunning了。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,732评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,496评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,264评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,807评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,806评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,675评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,029评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,683评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 41,704评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,666评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,773评论 1 332
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,413评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,016评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,978评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,204评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,083评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,503评论 2 343

推荐阅读更多精彩内容

  • Android Handler机制系列文章整体内容如下: Android Handler机制1之ThreadAnd...
    隔壁老李头阅读 4,244评论 2 12
  • 一.线程安全性 线程安全是建立在对于对象状态访问操作进行管理,特别是对共享的与可变的状态的访问 解释下上面的话: ...
    黄大大吃不胖阅读 828评论 0 3
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,596评论 18 139
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,573评论 18 399
  • 近来焕跟换了个人是似的,做作业拖拉,书写不端正,跟你对着干,我们说什么都是错的,一不顺心就翻脸……不知该怎...
    晴冰阅读 227评论 0 0