java Future模式的使用

一、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;

    }

}

巴特西

java Future模式的使用

一、Future模式的使用。

Future模式简述

主要角色

二、实现代码

最新文章

热门文章