码迷,mamicode.com
首页 > 其他好文 > 详细

并发模型(一)——Future模式

时间:2017-11-02 00:59:23      阅读:175      评论:0      收藏:0      [点我收藏+]

标签:cli   封装   image   start   static   读写   system   public   并发控制   

  多线程开发可以更好的发挥多核cpu性能,常用的多线程设计模式有:Future、Master-Worker、Guard Susperionsion、不变、生产者-消费者 模式;

jdk除了定义了若干并发的数据结构,也内置了多线程框架和各种线程池;    锁(分为内部锁、重入锁、读写锁)、ThreadLocal、

信号量等在并发控制中发挥着巨大的作用。这里重点介绍第一种并发——Future模型。

一、什么是Future模型:

    该模型是将异步请求和代理模式联合的模型产物。类似商品订单模型。见下图:

技术分享

客户端发送一个长时间的请求,服务端不需等待该数据处理完成便立即返回一个伪造的代理数据(相当于商品订单,不是商品本身),用户也无需等待,先去执行其他的若干操作后,再去调用服务器已经完成组装的真实数据。该模型充分利用了等待的时间片段。

 二、Future模式的核心结构:

(1)Main函数:

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());  
          
          
    }  
      
}  

Client的实现:

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;  
    }  
}  

Data的实现:

public interface Data {  
  
    public  String getResult();  
}  

FutureData:

/** 
 * 是对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;  
    }  
  
}  

RealData实现:

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;  
    }  
  
}  

注意:

    FutureData是对RealData的包装,是dui真实数据的一个代理,封装了获取真实数据的等待过程。它们都实现了共同的接口,所以,针对客户端程序组是没有区别的;

    客户端在调用的方法中,单独启用一个线程来完成真实数据的组织,这对调用客户端的main函数式封闭的;

    因为咋FutureData中的notifyAll和wait函数,主程序会等待组装完成后再会继续主进程,也就是如果没有组装完成,main函数会一直等待。

并发模型(一)——Future模式

标签:cli   封装   image   start   static   读写   system   public   并发控制   

原文地址:http://www.cnblogs.com/duan2/p/7769109.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!