JAVA并发处理经验(四)并行模式与算法2:Future模式
2016-01-16 13:58
591 查看
一、前言
首先我举个例子说明一下:你(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,最后得到的数据才是Resultpackage 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模式实现一些很慢的处理程序,中间你又要做其他事情的东西,或者你根本不用管理这;
相关文章推荐
- JAVA加密解密之Base64
- Java的IO流与对象的序列化浅谈
- 【Java】八个常用的排序算法:插入排序、冒泡排序、选择排序、希尔排序 、快速排序、归并排序、堆排序和LST基数排序
- 使用maven构建XML风格的Spring4 MVC应用
- javac编译后出现乱码错误
- 【Java】动态模拟时钟
- 一个经典的例子让你彻彻底底理解java回调机制
- 【Java】递归算法计算阶乘
- spring mvc中controller使用介绍
- java 图片像素质量压缩与图片长宽缩放
- JAVA文件压缩、解压
- Maven导入eclipse缺少web-resources目录
- 【Java】判断字符串是否为数字的方法
- java组装json和提取一个json的例子
- Java设计模式——适配器设计模式
- Java线程未捕获异常处理
- 深入理解java异常处理机制
- struts2 使用ajax 传递json数据
- cmd运行java 找不到或无法加载主类的问题
- Java实现通过smtp服务器验证邮箱的真实有效性