future模式

future模式

多线程的设计模式

future模式优点类似于商品订单。

比如：当订单处理完成后，在家等待送货上门即可，或者说我们Ajax请求的时候，页面是异步的进行后台处理，用户无须一直等待请求的结果，可以继续浏览或者操作其他内容。

示例demo：

public class FutureClient {
    /**
     * 在发送请求时,先返回一个futureData给生产着,
     * 与此同时,启动一个新的线程执行业务逻辑,没有返回真实的结果
     * 在线程中,执行需要处理的业务逻辑,完成后,将处理结果存放到RealData中
     *
     * @param queryStr
     * @return Data
     */
    public Data request(final String queryStr) {
        FutureData futureData = new FutureData();
        new Thread(() -> {
            final RealData realData = new RealData(queryStr);
            futureData.setRealData(realData);
        }).start();
        return futureData;
    }
}

public class FutureData implements Data {
    private RealData realData;
    private boolean isReady = false;

    public synchronized void setRealData(RealData realData) {
        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();
    }
}

public interface Data {
    String getRequest();
}

public class RealData implements Data {
    private final String result;

    public RealData(String queryStr) {
        System.out.println("真实的逻辑处理，在这可能耗时很久…");
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("任务处理完了…");
        String res = "业务处理的结果:" + queryStr.hashCode();
        // 将处理结果赋给result
        result = res;
    }

    @Override
    public String getRequest() {
        return this.result;
    }
}

public static void main(String[] args) {
    FutureClient futureClient = new FutureClient();
    Data data = futureClient.request("请求参数");
    System.out.println("请求发送成功");
    String result = data.getRequest();
    System.out.println(result);
}