`
y806839048
  • 浏览: 1117451 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

Future模式

阅读更多

异步的两种实现方式

1,主线程子线程靠管道通信

2,主线程子线程,利用一个类中多个同步块,不同线程访问不同块也会阻塞的原理(主线程不调用这中同步块方法仍可以继续向下执行

只要调到这个类的同步块,(子线程是这个类的其他同步块)此时才会阻塞)

 

 

多线程开发可以更好的发挥多核cpu性能,常用的多线程设计模式有:Future、Master-Worker、Guard Susperionsion、不变、生产者-消费者 模式;jdk除了定义了若干并发的数据结构,也内置了多线程框架和各种线程池;    锁(分为内部锁、重入锁、读写锁)、ThreadLocal、信号量等在并发控制中发挥着巨大的作用。这里重点介绍第一种并发——Future模型。

一、什么是Future模型:

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

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

 二、Future模式的核心结构:

    

Main:启动系统,调用Client发出请求;

Client:返回Data对象,理解返回FutureData,并开启ClientThread线程装配RealData;

Data:返回数据的接口;

FutureData:Future数据,构造很快,但是是一个虚拟的数据,需要装配RealData;

RealData:真实数据,构造比较慢。

三、Future模式的代码实现:

(1)Main函数:

 

[java] view plain copy
 
  1. <span style="font-size:18px;">package tgb;  
  2.   
  3. public class Main {  
  4.       
  5.     public static void main(String[] args){  
  6.         Client client = new Client();  
  7.         //理解返回一个FutureData  
  8.         Data data = client.request("name");  
  9.         System.out.println("请求完毕!");  
  10.           
  11.         try{  
  12.               
  13.             //处理其他业务  
  14.             //这个过程中,真是数据RealData组装完成,重复利用等待时间  
  15.             Thread.sleep(2000);           
  16.               
  17.         }catch (Exception e){  
  18.               
  19.         }  
  20.           
  21.         //真实数据  
  22.         System.out.println("数据 = "+ data.getResult());  
  23.           
  24.           
  25.     }  
  26.       
  27. }  
  28. </span>  

 

 

(2)Client的实现:

 

[java] view plain copy
 
  1. <span style="font-size:18px;">package tgb;  
  2.   
  3. public class Client {  
  4.   
  5.     public Data request(final String queryStr){  
  6.         final FutureData future = new FutureData();  
  7.         //开启一个新的线程来构造真实数据  
  8.         new Thread(){  
  9.             public void run(){  
  10.                 RealData realData = new RealData(queryStr);  
  11.                 future.setRealData(realData);           }  
  12.         }.start();  
  13.         return future;  
  14.     }  
  15. }  
  16. </span>  

 

 


(3)Data的实现:

 

[java] view plain copy
 
  1. <span style="font-size:18px;">package tgb;  
  2.   
  3. public interface Data {  
  4.   
  5.     public  String getResult();  
  6. }  
  7. </span>  

 

 


(4)FutureData:

 

[java] view plain copy
 
  1. <span style="font-size:18px;">package tgb;  
  2.   
  3. /** 
  4.  * 是对RealData的一个包装 
  5.  * @author limin 
  6.  * 
  7.  */  
  8. public class FutureData implements Data {  
  9.   
  10.     protected RealData realData =null;  
  11.     protected boolean isReady = false;  
  12.     public synchronized void setRealData(RealData realData){  
  13.         if(isReady){  
  14.             return;  
  15.         }  
  16.         this.realData=realData;  
  17.         isReady=true;  
  18.         notifyAll();  
  19.           
  20.     }  
  21.       
  22.     @Override  
  23.     public  synchronized  String getResult() {  
  24.         while(!isReady){  
  25.             try{  
  26.                 wait();  
  27.             }catch (Exception e){  
  28.                   
  29.             }  
  30.         }  
  31.         return realData.result;  
  32.     }  
  33.   
  34. }  
  35. </span>  

 

 


(5)RealData实现:

 

[java] view plain copy
 
  1. <span style="font-size:18px;">package tgb;  
  2.   
  3. public class RealData implements Data {  
  4.     protected  String  result;  
  5.       
  6.     public RealData(String para){  
  7.          //构造比较慢  
  8.         StringBuffer sb= new StringBuffer();  
  9.         for(int i=0;i<10;i++){  
  10.             sb.append(para);  
  11.             try{  
  12.                 Thread.sleep(1000);  
  13.             }catch(Exception e){  
  14.                   
  15.             }  
  16.             result= sb.toString();  
  17.         }  
  18.     }  
  19.       
  20.       
  21.       
  22.     @Override  
  23.     public String getResult() {  
  24.   
  25.         return result;  
  26.     }  
  27.   
  28. }  
  29. </span>  

 

 

 

注意:

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

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

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

分享到:
评论

相关推荐

    31 凭票取餐—Future模式详解.pdf

    【31 凭票取餐—Future模式详解】 在Java并发编程中,Future模式是一种常见的设计模式,它允许主线程在不阻塞的情况下启动一个异步任务,然后在需要时获取任务的结果。Future模式的灵感来源于现实生活中的场景,如...

    future模式案例代码

    Future模式核心思想是异步调用,这里具体实现代码,其思想是:网上订了一个货之后,他会立即返回下好订单给你,你可以去做其他事,不用再一直等这个货物到达,以后有时间,货物到了,你就可以拿这个订单,去取货。...

    Spring Boot对Future模式的支持详解

    Spring Boot对Future模式的支持使得开发者可以更方便地在应用程序中实现异步处理,从而提高系统的并发性能和响应速度。在实际开发中,当遇到需要执行耗时操作或复杂计算时,我们可以利用多线程来提升效率,而Future...

    老生常谈java中的Future模式

    老生常谈java中的Future模式 在 Java 中,Future 模式是一种常用的设计模式,用于处理并发编程中的多线程问题。在这个模式中,线程 A 需要等待线程 B 的结果,但线程 A 不需要一直等待线程 B,可以先拿到一个未来的...

    asyncj:使用 Future 模式或回调(NodeJS 风格)进行异步非阻塞编程的灵活而简单的库。 没有第三方依赖,没有重量级的包装器和类,没有废话,只需添加 maven 依赖并构建可扩展的应用程序

    灵活且超轻量级的库,用于使用 Future 模式、回调(NodeJS 风格)和异步非阻塞编程。 动机 该库的第一个目标是为 Java 8 提供模式的轻量级实现。此外,该库还提供对 Java 流水线的支持。 第二个目的是演示 Java 8 ...

    nio+Future.rar

    在Java编程领域,NIO(New Input/Output)和Future模式是两个重要的概念,它们分别在并发处理和异步操作中发挥着关键作用。这里我们将深入探讨这两个知识点,并结合压缩包中的"nioStudy"文件来解析它们的应用。 一...

    Callable和Future.doc

    Java 中的 Future 模式允许我们提交一个异步任务并获取其结果,而无需直接管理线程。我们可以在提交任务后继续执行其他操作,稍后再通过 Future 对象获取结果。这种方式提高了程序的并发性和灵活性。 在实际应用中...

    简单讲解Java的Future编程模式

    Future模式的优势在于它能够将异步的数据驱动自然地融入到顺序流程中,使得并发代码保持简洁和优雅。与回调驱动相比,Future模式避免了回调函数中可能出现的线程安全问题,同时提供了更好的顺序流程控制。回调虽然...

    java多线程设计模式详解

    Future模式允许启动一个异步操作,并在后续代码中获取结果。Java的`Future`接口和`Callable`接口结合`ExecutorService`可以实现这一模式,提高程序的响应速度。 八、线程局部变量模式 线程局部变量(`ThreadLocal`)...

    JAVA设计模式

    5. **Future模式**:Future模式是一种并发设计模式,它提供了异步操作的结果。在Java中,`java.util.concurrent.Future`接口代表一个异步计算的结果,可以检查计算是否完成,取消计算,或者获取计算结果。通常与...

    并发设计模式

    - Future模式:异步执行任务并返回结果,提供了一种机制来获取异步任务的结果。 - 生产者消费者模式:管理不同线程之间的数据交换。 #### 三、单例模式详解 单例模式是一种常用的创建型设计模式,它确保一个类...

    java多线程设计模式详解.pdf

    3. 同步和通信模式:探讨在多线程程序中,线程间的同步机制和通信手段,如信号量、栅栏、Future模式等。 4. 并发集合和映射的设计模式:介绍在多线程环境中,如何安全地使用集合数据结构,以及专门针对并发访问设计...

    多线程设计模式.rar

    7. **future模式**:future模式用于异步计算的结果获取。Java的`Future`接口和`Callable`接口配合`ExecutorService`,可以预提交任务并在未来某个时刻获取结果。 8. **竞争条件(Race Condition)和死锁避免**:在...

    线程超时死掉

    Future接口是Java线程Future模式的实 现,可以来进行异步计算。 Future模式可以这样来描述:我有一个任务,提交给了Future,Future替我完成这个任务。期间我自己可以去做任何想做的事情。一段时 间之后,我就便...

    Java多线程设计模式.pdf

    **定义:**Future模式是一种允许客户端异步地获取结果的模式。它提供了一个代理对象(Future),该对象代表了某个正在进行的任务的结果。 **关键要素:** - `Future`接口:表示计算结果的未来可用性。 - `...

    Java并发编程的设计原则与模式

    5. **future模式**:Future接口代表异步计算的结果,可以查询计算是否完成,获取结果,甚至取消计算。CompletableFuture提供更强大的异步编程支持。 四、Java并发工具 1. **CountDownLatch**:用于计数,当计数到达...

    java多线程设计模式

    7. **Future模式**:异步编程模型中的一种设计模式,用户提交一个任务并获取一个Future对象,当任务完成时可以通过Future对象获取结果。 8. **责任链模式**:将多个处理步骤组织成一条链,每个处理步骤负责一部分...

    java多线程设计模式详解.rar

    6. **future模式**:`Future`接口和`Callable`接口一起使用,可以异步执行任务并获取结果。这在等待某个耗时操作完成,而不阻塞当前线程的情况下非常有用。 7. **线程间通信模式**:`wait()`、`notify()`和`...

    设计模式-.NET并行编程

    本书共7章:第1章主要介绍并行编程的基本概念与并行计算的基础理论,第2章主要介绍并行循环的知识,第3章介绍并行任务处理,第4章阐述并行合并计算的机理,第5章介绍future模式,第6章在前文的基础上深入探讨动态...

Global site tag (gtag.js) - Google Analytics