Future模式介绍及入门使用

FutureClient代码实现:

package com.hjf.future;

public class FutureClient
{
    /**
     * 请求客户端
     * @param queryStr
     * @return
     */
    public Data request(final String queryStr){
        //1:创建一个代理对象(Data接口的实现类)先返回给发送请求的客户端，告诉他请求已经接收到，可以做其他的事情
        final FutureData fd = new FutureData();
        //2:启动一个新的线程，去加载真实的数据，传递给这个代理对象
        new Thread(new Runnable()
        {
            @Override
            public void run()
            {
                //3:这个新的线程可以去后台加载真实的数据
                RealDate rd = new RealDate(queryStr);
                //4:传递给代理对象
                fd.setRealData(rd);
            }
        }).start();
        //5:返回代理对象
        return fd;
    }
}

FutureData代码及实现:

package com.hjf.future;

public class FutureData implements Data
{
    /*真实数据*/
    private RealDate realData;
    
    /*是否加载完成的控制器*/
    private boolean isready = false;
    
    /**
     * 装载真实的数据
     * @param realData
     */
    public synchronized void setRealData(RealDate realData)
    {
        //realData已经装载到FutureData中了，直接返回
        if(isready){
            return;
        }
        this.realData = realData;//装载数据
        isready = true;//修改控制器
        notify();
    }
    
    /**
     * 获取请求的最终结果
     */
    @Override
    public synchronized String getRequest()
    {
        //未加载数据的情况下保持等待 等待状态真实数据完成
        while(!isready){
            try
            {
                wait();
            } catch (InterruptedException e)
            {
                e.printStackTrace();
            }
        }
        //装载完成时获取数据即可
        return this.realData.getRequest();
    }

}

RealData代码及实现:

package com.hjf.future;

public class RealDate implements Data
{
    /*查询结果*/
    private String result;

    public RealDate(String queryStr){
        System.out.println("根据 "+queryStr+" 进行查询，这是一个很耗时的操作..");
        try
        {
            //模拟真实的情况
            Thread.sleep(5000);
        } catch (InterruptedException e)
        {
            e.printStackTrace();
        }
        System.out.println("操作完毕，获取数据");
        this.result = "查询结果";
    }
    
    /**
     * 获取真实的请求数据
     * @return
     */
    @Override
    public String getRequest()
    {
        return result;
    }
}

Data接口代码:

package com.hjf.future;

public interface Data
{
    String getRequest();
}

测试类代码:

package com.hjf.future;

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