A-A+

大话Future模式

2016年05月17日 Java 暂无评论 阅读 785 views 次

说在前面的话

什么是Future 模式呢？对于多线程，如果线程A要等待线程B的结果，那么线程A没必要等待B，直到B有结果，可以先拿到一个未来的Future，等B有结果是再取真实的结果。其实这个模式用的很多，比如浏览器下载图片的时候，刚开始是不是通过模糊的图片来代替最后的图片，等下载图片的线程下载完图片后在替换。

Future

思想

future2

实例

Main：系统启动，调用Client发出请求

  1. package com.ifcoding.future;
  3. public class Main {
  5.     public static void main(String[] args) {
  6.         //1. 创建client
  7.         Client client = new Client();
  8.         //2. client请求，得到FutureData
  9.         Data data = client.request("name");
  10.         System.out.println("请求完毕！");
  11.         try {
  12.             Thread.sleep(2000);
  13.         } catch (Exception e) {
  14.         }
  15.         System.out.println("数据=" + data.getResult());
  16.     }
  18. }

Client：返回Data对象，立即返回FutureData，并开启ClientThread线程装配RealData

  1. package com.ifcoding.future;
  3. public class Client {
  5.     public Data request(final String queryStr) {
  6.         final FutureData future = new FutureData();
  7.         new Thread(){
  8.             @Override
  9.             public void run() {
  10.                 RealData realdata = new RealData(queryStr);
  11.                 future.setRealData(realdata);
  12.             }
  14.         }.start();
  16.         return future;
  17.     }
  19. }

Data：返回数据的接口

  1. package com.ifcoding.future;
  3. public interface Data {
  4.     public String getResult();
  5. }

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

  1. package com.ifcoding.future;
  3. public class FutureData implements Data {
  4.     protected RealData realdata = null;
  5.     protected boolean isReady = false;
  7.     public synchronized void setRealData(RealData realdata) {
  8.         if (isReady) {
  9.             return;
  10.         }
  11.         this.realdata = realdata;
  12.         isReady = true;
  13.         notifyAll();
  14.     }
  16.     @Override
  17.     public String getResult() {
  18.         if (!isReady) {
  19.             try {
  20.                 wait();
  21.             } catch (Exception e) {
  23.             }
  24.         }
  25.         return realdata.result;
  26.     }
  28. }

RealData：真实数据，其构造是比较慢的

  1. package com.ifcoding.future;
  3. public class RealData implements Data{
  5.     public final String result;
  7.     public RealData(String queryStr) {
  8.         StringBuffer sb = new StringBuffer();
  9.         for (int i = 0; i < 10; i++) {
  10.             sb.append(queryStr + " ");
  11.             try {
  12.                 Thread.sleep(100);
  13.             } catch (Exception e) {
  14.             }
  15.         }
  16.         result = sb.toString();//实际要获得数据
  17.     }
  19.     @Override
  20.     public String getResult() {
  21.         return result;
  22.     }
  24. }
标签：

给我留言

CAPTCHA

*

Copyright © If Coding 保留所有权利.   Theme  Ality   

用户登录