Java多线程--Future及FutureTask

1、Future
线程是异步的,所以不可能直接从别的线程中得到函数返回值。Futrue可以监视目标线程调用call的情况,当调用Future的get()方法获得结果时,当前线程就开始阻塞,直接call方法结束返回结果
任务提交给Future,由Future控制Executor来完成这个任务。一段时间后,可以从Future那儿取出结果。
Future接口是Future<V>,其中V代表了Future执行的任务返回值的类型。

Future接口的方法介绍:
boolean cancel (boolean mayInterruptIfRunning)
取消任务的执行。参数指定是否立即中断任务,或者等待一会结束
boolean isCancelled ()
任务是否已经取消,任务正常完成前将其取消,则返回true
boolean isDone ()
任务是否已经完成。如果任务正常终止、异常或取消,都将返回true
V get () throws InterruptedException, ExecutionException
等待任务执行结束,然后获得V类型的结果。InterruptedException线程被中断的异常,ExecutionException任务执行的异常,如果任务被取消,还会抛出CancellationException
V get (long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
同上面的get功能一样,多了设置超时时间。超时,将抛出TimeoutException

下面是一个使用Future计算Fibonacci数列的demo
通过future.get()取得Callable的返回结果,用于后面的计算

import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class Future20170322 {
    static int f0 = 1;
    static int f1 = 1;
    static int f2 = 0;
    
    public static void main(String[] args) {
        ExecutorService threadPool = Executors.newSingleThreadExecutor();

        for(int i=2; i<10; i++) {
            Future<Integer> future = threadPool.submit(new Callable<Integer>() {
                public Integer call() throws Exception {
                    return f0 + f1;
                }
            });
            try {
                f2 = future.get();
                f0 = f1;
                f1 = f2;
                System.out.println(f2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
    }
}

2、FutureTask
为什么要使用FutureTask?
Future可以通过Future.get()来取得计算结果。但是,若开启了多个任务,就不知道哪个任务最先结束。因此,若要实现 “当某任务结束时,立刻做某些事情”这一功能,就需要写一些额外的代码

package FutureTask20170329;

import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;

public class FutureTask20170329 { 
    
    public static void main(String[] args) {  
        ExecutorService executor = Executors.newCachedThreadPool();  
        //循环创建5个任务,并把他放到FutureTask中
        for(int i=0; i<5; i++) {
            Callable<String> c = new Task();  
            MyFutureTask ft = new MyFutureTask(c);  
            executor.submit(ft);  
        }  
        executor.shutdown();  
    }  
          
}  
  
class MyFutureTask extends FutureTask<String> {  
  
    public MyFutureTask(Callable<String> callable) {  
        super(callable);  
    }  
  
    //回调函数,当任务完成时就会被出发
    @Override  
    protected void done() {  
        try {  
            System.out.println(get() + " 线程执行完毕!");  
        } catch (InterruptedException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        } catch (ExecutionException  e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }  
    }  
      
      
}  
  
//创建一个任务,随机睡眠10s之内
class Task implements Callable<String> {  
  
    public String call() throws Exception {  
        Random rand = new Random();  
        Thread.sleep(rand.nextInt(10));  
        return Thread.currentThread().getName();  
    }  
} 

执行结果:


Paste_Image.png

从结果可以看出,每个线程执行完毕都会知道,所以可以在其中加入任务完毕之后所需的操作。
使用遍历的方式虽然也可以解决取得多任务结果的问题,但却不是最优的效果,FutureTask正是为此而存在,它有一个回调函数protected void done(),当任务结束时,该回调函数会被触发。因此,只需重载该函数,即可实现在线程刚结束时就做某些事情

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

推荐阅读更多精彩内容