了解JAVA Future类

1. future的应用场景

在并发编程中，我们经常用到非阻塞的模型，在之前的多线程的三种实现中，不管是继承thread类还是实现runnable接口，都无法保证获取到之前的执行结果。通过实现callback接口，并用future可以来接收多线程的执行结果。

future表示一个可能还没有完成的异步任务的结果，针对这个结果可以添加callback以便在任务执行成功或失败后作出相应的操作。

举个例子：比如去吃早点时，点了包子和凉菜，包子需要等3分钟，凉菜只需1分钟，如果是串行的一个执行，在吃上早点的时候需要等待4分钟，但是因为你在等包子的时候，可以同时准备凉菜，所以在准备凉菜的过程中，可以同时准备包子，这样只需要等待3分钟。那future这种模式就是后面这种执行模式。

2. future的类图结构

future接口定义了主要的5个接口方法，有runnablefuture和schedualfuture继承这个接口，以及completefuture和forkjointask继承这个接口。

runnablefuture

这个接口同时继承future接口和runnable接口，在成功执行run（）方法后，可以通过future访问执行结果。

这个接口都实现类是futuretask,一个可取消的异步计算，这个类提供了future的基本实现，后面我们的demo也是用这个类实现，它实现了启动和取消一个计算，查询这个计算是否已完成，恢复计算结果。计算的结果只能在计算已经完成的情况下恢复。

如果计算没有完成，get方法会阻塞，一旦计算完成，这个计算将不能被重启和取消，除非调用runandreset方法。

futuretask能用来包装一个callable或runnable对象，因为它实现了runnable接口，而且它能被传递到executor进行执行。为了提供单例类，这个类在创建自定义的工作类时提供了protected构造函数。

schedualfuture

这个接口表示一个延时的行为可以被取消。通常一个安排好的future是定时任务schedualedexecutorservice的结果

completefuture

一个future类是显示的完成，而且能被用作一个完成等级，通过它的完成触发支持的依赖函数和行为。当两个或多个线程要执行完成或取消操作时，只有一个能够成功。

forkjointask

基于任务的抽象类，可以通过forkjoinpool来执行。一个forkjointask是类似于线程实体，但是相对于线程实体是轻量级的。大量的任务和子任务会被forkjoinpool池中的真实线程挂起来，以某些使用限制为代价。

3. future的主要方法

future接口主要包括5个方法

get（）方法可以当任务结束后返回一个结果，如果调用时，工作还没有结束，则会阻塞线程，直到任务执行完毕

get（long timeout,timeunit unit）做多等待timeout的时间就会返回结果

cancel（boolean mayinterruptifrunning）方法可以用来停止一个任务，如果任务可以停止（通过mayinterruptifrunning来进行判断），则可以返回true,如果任务已经完成或者已经停止，或者这个任务无法停止，则会返回false.

isdone（）方法判断当前方法是否完成

iscancel（）方法判断当前方法是否取消

4. future示例demo

需求场景：等早餐过程中，包子需要3秒，凉菜需要1秒，普通的多线程需要四秒才能完成。先等凉菜，再等包子，因为等凉菜时，普通多线程启动start()方法，执行run()中具体方法时，没有返回结果，所以如果要等有返回结果，必须是要1秒结束后才知道结果。

普通多线程：

public class bumthread extends thread{
@override
public void run() {
try {
thread.sleep(1000*3);
system.out.println("包子准备完毕");
} catch (interruptedexception e) {
e.printstacktrace();
}
}
}
public class colddishthread extends thread{
@override
public void run() {
try {
thread.sleep(1000);
system.out.println("凉菜准备完毕");
} catch (interruptedexception e) {
e.printstacktrace();
}
}
}
public static void main(string[] args) throws interruptedexception {
long start = system.currenttimemillis();
// 等凉菜 -- 必须要等待返回的结果，所以要调用join方法
thread t1 = new colddishthread();
t1.start();
t1.join();
// 等包子 -- 必须要等待返回的结果，所以要调用join方法
thread t2 = new bumthread();
t2.start();
t2.join();
long end = system.currenttimemillis();
system.out.println("准备完毕时间："+(end-start));
}

采用future模式：

public static void main(string[] args) throws interruptedexception, executionexception {
long start = system.currenttimemillis();
// 等凉菜 
callable ca1 = new callable(){
@override
public string call() throws exception {
try {
thread.sleep(1000);
} catch (interruptedexception e) {
e.printstacktrace();
}
return "凉菜准备完毕";
}
};
futuretask<string> ft1 = new futuretask<string>(ca1);
new thread(ft1).start();
// 等包子 -- 必须要等待返回的结果，所以要调用join方法
callable ca2 = new callable(){
@override
public object call() throws exception {
try {
thread.sleep(1000*3);
} catch (interruptedexception e) {
e.printstacktrace();
}
return "包子准备完毕";
}
};
futuretask<string> ft2 = new futuretask<string>(ca2);
new thread(ft2).start();
system.out.println(ft1.get());
system.out.println(ft2.get());
long end = system.currenttimemillis();
system.out.println("准备完毕时间："+(end-start));

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。