多线程设计模式(二):Future模式
2024-08-24 12:33:58
一、什么是Future模型:
该模型是将异步请求和代理模式联合的模型产物。类似商品订单模型。见下图:
客户端发送一个长时间的请求,服务端不需等待该数据处理完成便立即返回一个伪造的代理数据(相当于商品订单,不是商品本身),用户也无需等待,先去执行其他的若干操作后,再去调用服务器已经完成组装的真实数据。该模型充分利用了等待的时间片段。
二、Future模式的核心结构:
Main:启动系统,调用Client发出请求;
Client:返回Data对象,理解返回FutureData,并开启ClientThread线程装配RealData;
Data:返回数据的接口;
FutureData:Future数据,构造很快,但是是一个虚拟的数据,需要装配RealData;
RealData:真实数据,构造比较慢。
三、Future模式的代码实现:
(1)Main函数:
- <span style="font-size:18px;">package tgb;
- public class Main {
- public static void main(String[] args){
- Client client = new Client();
- //理解返回一个FutureData
- Data data = client.request("name");
- System.out.println("请求完毕!");
- try{
- //处理其他业务
- //这个过程中,真是数据RealData组装完成,重复利用等待时间
- Thread.sleep(2000);
- }catch (Exception e){
- }
- //真实数据
- System.out.println("数据 = "+ data.getResult());
- }
- }
- </span>
(2)Client的实现:
- <span style="font-size:18px;">package tgb;
- public class Client {
- public Data request(final String queryStr){
- final FutureData future = new FutureData();
- //开启一个新的线程来构造真实数据
- new Thread(){
- public void run(){
- RealData realData = new RealData(queryStr);
- future.setRealData(realData); }
- }.start();
- return future;
- }
- }
- </span>
(3)Data的实现:
- <span style="font-size:18px;">package tgb;
- public interface Data {
- public String getResult();
- }
- </span>
(4)FutureData:
- <span style="font-size:18px;">package tgb;
- /**
- * 是对RealData的一个包装
- * @author limin
- *
- */
- public class FutureData implements Data {
- protected RealData realData =null;
- protected boolean isReady = false;
- public synchronized void setRealData(RealData realData){
- if(isReady){
- return;
- }
- this.realData=realData;
- isReady=true;
- notifyAll();
- }
- @Override
- public synchronized String getResult() {
- while(!isReady){
- try{
- wait();
- }catch (Exception e){
- }
- }
- return realData.result;
- }
- }
- </span>
(5)RealData实现:
- <span style="font-size:18px;">package tgb;
- public class RealData implements Data {
- protected String result;
- public RealData(String para){
- //构造比较慢
- StringBuffer sb= new StringBuffer();
- for(int i=0;i<10;i++){
- sb.append(para);
- try{
- Thread.sleep(1000);
- }catch(Exception e){
- }
- result= sb.toString();
- }
- }
- @Override
- public String getResult() {
- return result;
- }
- }
- </span>
注意:
FutureData是对RealData的包装,是dui真实数据的一个代理,封装了获取真实数据的等待过程。它们都实现了共同的接口,所以,针对客户端程序组是没有区别的;
客户端在调用的方法中,单独启用一个线程来完成真实数据的组织,这对调用客户端的main函数式封闭的;
因为咋FutureData中的notifyAll和wait函数,主程序会等待组装完成后再会继续主进程,也就是如果没有组装完成,main函数会一直等待。
转:http://blog.csdn.net/lmdcszh/article/details/39696357
最新文章
- Linux串口中的超时设置
- openWrt 安装与实践 II
- 拓扑排序(三)之 Java详解
- 网络热恋之json解析
- linux C学习笔记03--单链表
- python学习笔记22(group)
- (3)java棧
- 浏览器兼容问题汇总<;转>;
- 真实故事:网站遭遇DOS攻击
- Linux C++程序进行性能分析工具gprof使用入门
- PHP 7.2 新功能介绍
- MUI框架 按钮点击响应不好的问题解决办法
- 1GB pages can only be allocated at boot time using hugepages= and not freed afterwards
- Confluence 6 MySQL 数据库设置准备
- pandas的to_csv()使用方法
- jqgrid 行选中multiboxonly属性说明
- python之shutil模块详解
- 谨防in、or 公用性能问题
- 【Android】添加依赖包
- Ajax编程(HTTP请求与响应及API)详解
热门文章
- 英语发音规则---A字母
- spring3: Bean的命名与Bean的实例化
- easyui datagrid 行编辑功能
- 【Java】方法的重载与重写
- MVC框架中的值提供机制(一)
- 【PAT-L2-020】功夫传人
- Struts06---通配符的使用
- request.setAttribute(";username";, username);//一定要保存,OGNL才能获取${username}
- 不用配置 , 快速搭建react环境
- Activity has leaked window that was originally added(以解决)