一、前言
首先我举个例子说明一下：
你（client）要去海南的亲戚家里玩耍，你叫爸爸给你海南的二叔打电话告诉他你周六晚上8点得飞机到海南（call1只是通知），你真倒海南你二叔接到你了旅行得以完成（call2是真实结果）
本来准备画图的，但是还是来自互联网的图片，足以说明一下；
说明一下这个模式的几个要素：
| 参与 | 作用 |
| Main | 系统启动，调用clent |
| Client | 调用Data对象，立即返回Future，开启线程装配RealData |
| FutureData | Future数据，构造很快，但是需要装备真实realTure |
| RealData | 真实数据，但是构造比较慢 |
二、Future模式
2.1 首先需要一个Data 让Future与real都快要继承
package pattern.fature;
/**
* Created by ycy on 16/1/16.
*/
public interface Data {
public String getResult();
}
2.2 我们需要一个future，并开始装配realData
package pattern.fature;
import javafx.scene.chart.XYChart;
/**
* Created by ycy on 16/1/16.
*/
public class FutureDate implements Data {
protected RealData realData=null;//Future是realData的包装
protected boolean isReady=false;
public synchronized void setRealData(RealData realData){
if (isReady){
return;
}
this.realData = realData;
isReady=true;
notifyAll();//realDate 已经被注入,通知getResult
}
public String getResult() {
while (!isReady){
try {
wait();//一直等待,直到realData被注入
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return realData.result;//有realdata实现
}
}
2.3 是我们真正需要的数据realData
package pattern.fature;
/**
* Created by ycy on 16/1/16.
*/
public class RealData implements Data{
protected final String result;
public RealData(String para){
//RealData 的构造可能很慢,需要用户等待很久,这里用sleep代替
StringBuffer sb=new StringBuffer();
for (int i = 0; i <10 ; i++) {
sb.append(para);
}
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
result=sb.toString();
}
public String getResult() {
return result;
}
}
2.4 我们需要一个client去获取我们的future数据与real数据
package pattern.fature;
/**
* Created by ycy on 16/1/16.
*/
public class Client {
public Data request(final String queryStr){
final FutureDate futureDate=new FutureDate();
new Thread(){
@Override
public void run() {
RealData realData=new RealData(queryStr);
futureDate.setRealData(realData);
}
}.start();
return futureDate;
}
}
2.5是真正的调用的着main
我们先回去的data：是future，最后得到的数据才是Result
package pattern.fature;
/**
* Created by ycy on 16/1/16.
*/
public class Main {
public static void main(String[] args) {
Client client=new Client();
//这里会立即返回,因为得到的FutureData 而不是realData
Data data=client.request("name");
System.out.println("请求完毕");
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("数据="+data.getResult());
}
}
三、JDK中Future模式运用
3.1 构造我们真的数据realData
package pattern.fature.jdkFutrue;
import java.util.concurrent.Callable;
/**
* Created by ycy on 16/1/16.
*/
public class RealData implements Callable<String>{
private String para;
public RealData(String para){
this.para=para;
}
public String call() throws Exception {
StringBuilder sb=new StringBuilder();
for (int i = 0; i <10 ; i++) {
sb.append(para);
Thread.sleep(1000);
}
return sb.toString();
}
}
3.2 构造我们的调用main
package pattern.fature.jdkFutrue;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
/**
* Created by ycy on 16/1/16.
*/
public class FutureMian {
public static void main(String[] args) throws ExecutionException, InterruptedException {
//构造FutureTask
FutureTask<String> futureTask=new FutureTask<String>(new RealData("A"));
ExecutorService es= Executors.newFixedThreadPool(1);
//执行FutureTask,相当于上例中的client.request("a")发送请求
//在这里开启线程Realdata 的call执行
es.submit(futureTask);
//额外的操作
try {
Thread.sleep(2000);
System.out.println("ddd");
} catch (InterruptedException e) {
e.printStackTrace();
}
//相当于data.getResult(),取得call()方法的返回值,此时call方法没有执行完成,则会等待
if (futureTask.isDone()){
System.out.println("数据="+futureTask.get());
}
}
}
四、总结
适用future模式实现一些很慢的处理程序，中间你又要做其他事情的东西，或者你根本不用管理这；
