一、Future模式的使用。
Future模式简述
传统单线程环境下，调用函数是同步的，必须等待程序返回结果后，才可进行其他处理。 Futrue模式下，调用方式改为异步。
Futrue模式的核心在于：充分利用主函数中的等待时间，利用等待时间处理其他任务，充分利用计算机资源。
主要角色
Main：系统启动，调用Client发出请求
Client：返回Data对象，立即返回FutureData，并开启ClientThread线程装配
RealData Data：返回数据的接口
FutureData：Futrue数据，是一个虚拟的数据，需要装配RealData RealData：真实数据，构造比较慢
二、实现代码
Main类
public class Main { public static void main(String[] args) { FutureClient fc = new FutureClient(); Data data = fc.request("请求参数"); System.out.println("请求参数发送成功"); System.out.println("开始做其他事情"); String result = data.getRequest(); System.out.println(result); }}
FutureCliet类
public Data request(final String queryStr) { // 1 我想要一个代理对象（Data接口的实现类）先返回给发送请求的客户端， // 告诉他的请求已经收到，可以干其他事情 final FutureData futureData = new FutureData(); // 2.创建一个新的线程，去加载真是数据,传递个这个代理对象 new Thread(new Runnable() { @Override public void run() { // 3.这个新的线程可以慢慢去加载真是对象，然后传递给代理对象 RealData realData = new RealData(queryStr); futureData.setRealData(realData); } }).start(); return futureData; }
Data接口
public interface Data { String getRequest();}
FutureData
public class FutureData implements Data { private RealData realData; private boolean isReady = false; @Override public synchronized String getRequest() { // 如果没有装载好久一直处于阻塞状态 while (!isReady) { try { wait(); } catch (InterruptedException e) { e.printStackTrace(); } } // 装载好可以直接获取数据 return this.realData.getRequest(); } public synchronized void setRealData(RealData realData) { if (isReady) { return; } this.realData = realData; isReady = true; notify(); }}
RealData
public class RealData implements Data { private String result; public RealData() { } public RealData(String queryStr) { System.out.println("根据" + queryStr + "进行查询" + "这是一个很耗时间的操作..."); try { Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("操作完毕"); result = "查询结果"; } @Override public String getRequest() { return result; }}