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