多线程设计模式 - Future模式

简介: 一起来看看多线程设计模式中的Future模式吧~

概述


Future模式是多线程开发中非常常见的一种设计模式,它的核心思想是异步调用。这类似我们日常生活中的在线购物流程,带在购物网看着一件商品时可以提交表单,当订单完成后就可以在家里等待商品送货上门。或者说更形象的是我们发送Ajax请求的时候,页面是异步的进行后台处理,用户无需等待请求的结果,可以继续浏览或操作其他内容。


1.png

如上图所示,客户端调用购物请求,服务端程序不等数据处理完成便立即返回客户端一个伪造的数据,(相当于订单,而不是真实的商品)这时候由服务端自己偷偷摸摸的发送了一个other call()请求去获取真实的商品(打包,出库,送货)。这就是Future模式的核心所在。


Future模式的主要角色有:


Main:系统启动,调用FutureClient发出请求


FutureClient:返回Data对象,立即返回FutureData,并开启线程去获取RealData


Data:返回数据的接口


FutureData:虚拟数据,返回很快,需要装载RealData


RealData:真实数据


代码实战


根据上面的介绍我们用代码来模拟一下具体的实现过程:


Main:


publicclassMain {    publicstaticvoidmain(String[] args) {        FutureClientfc=newFutureClient();        Datadata=fc.getRequset("jianzh5");        System.out.println("请求完毕...");        Stringresult=data.getRequest();        System.out.println("返回的结果:"+result);    }}

此类主要调用FutureClient的getRequset方法去返回数据


FutureClient:


publicclassFutureClient {    publicDatagetRequset(finalStringqueryStr){        //初始化代理对象,先返回给客户端        final FutureData futureData = new FutureData();        //启动一个新的线程去加载真实的数据,传递给这个代理对象        new Thread(new Runnable() {            @Override public void run() {                //此线程去加载真实对象,然后传递给代理对象                RealData realData = new RealData(queryStr);                futureData.setRealData(realData);            }        }).start();        System.out.println("代理对象返回:"+futureData);        return futureData;    }}


该类在接受到用户请求后很快就能返回虚拟数据 futureData,本身启动一个线程去获取真实数据


RealData:


publicclassRealDataimplementsData{    privateStringresult;    publicRealData(StringqueryStr){        System.out.println("根据参数: "+queryStr+" 进行查询,这是一个很耗时的操作!");        try {            Thread.sleep(5000);        } catch (InterruptedExceptione) {            e.printStackTrace();        }        System.out.println("装载完毕,获取结果");        result="查询结果";    }    @OverridepublicStringgetRequest() {        returnresult;    }}


RealData装载数据较慢,这里使用Sleep(5000)模拟复杂业务逻辑。


FutureData:


publicclassFutureDataimplementsData{    privateRealDatarealData;    privatebooleanisReady=false;    publicsynchronizedvoidsetRealData(RealDatarealData){        //如果已经装载完毕则直接返回        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();    }}


该类是Future模式的关键,它实际是真实数据RealData的代理,封装了获取RealData的等待过程实际返回的是真实的数据。


其实在JDK内部类已经实现了Future模式,详细内容我们下期再聊!


目录
相关文章
|
6月前
|
存储 Java
高并发编程之多线程锁和Callable&Future 接口
高并发编程之多线程锁和Callable&Future 接口
77 1
|
6月前
|
存储 缓存 Java
9.队列:生产消费模式及线程池的运用
9.队列:生产消费模式及线程池的运用
58 0
|
4月前
|
缓存 Java 调度
Java并发编程:深入解析线程池与Future任务
【7月更文挑战第9天】线程池和Future任务是Java并发编程中非常重要的概念。线程池通过重用线程减少了线程创建和销毁的开销,提高了资源利用率。而Future接口则提供了检查异步任务状态和获取任务结果的能力,使得异步编程更加灵活和强大。掌握这些概念,将有助于我们编写出更高效、更可靠的并发程序。
|
3月前
|
NoSQL Redis
Lettuce的特性和内部实现问题之在同步调用模式下,业务线程是如何拿到结果数据的
Lettuce的特性和内部实现问题之在同步调用模式下,业务线程是如何拿到结果数据的
|
3月前
|
NoSQL 关系型数据库 MySQL
简述redis的单线程模式
简述redis的单线程模式
|
4月前
|
Prometheus 监控 数据可视化
通用快照方案问题之Hystrix进行指标监控如何解决
通用快照方案问题之Hystrix进行指标监控如何解决
43 0
|
4月前
|
设计模式 安全 NoSQL
Java面试题:设计一个线程安全的单例模式,并解释其内存占用和垃圾回收机制;使用生产者消费者模式实现一个并发安全的队列;设计一个支持高并发的分布式锁
Java面试题:设计一个线程安全的单例模式,并解释其内存占用和垃圾回收机制;使用生产者消费者模式实现一个并发安全的队列;设计一个支持高并发的分布式锁
65 0
|
4月前
|
存储 设计模式 监控
Java面试题:如何在不牺牲性能的前提下,实现一个线程安全的单例模式?如何在生产者-消费者模式中平衡生产和消费的速度?Java内存模型规定了变量在内存中的存储和线程间的交互规则
Java面试题:如何在不牺牲性能的前提下,实现一个线程安全的单例模式?如何在生产者-消费者模式中平衡生产和消费的速度?Java内存模型规定了变量在内存中的存储和线程间的交互规则
47 0
|
6月前
|
缓存 NoSQL 中间件
【后端面经】【缓存】36|Redis 单线程:为什么 Redis 用单线程而 Memcached 用多线程?epoll、poll和select + Reactor模式
【5月更文挑战第19天】`epoll`、`poll`和`select`是Linux下多路复用IO的三种方式。`select`需要主动调用检查文件描述符,而`epoll`能实现回调,即使不调用`epoll_wait`也能处理就绪事件。`poll`与`select`类似,但支持更多文件描述符。面试时,重点讲解`epoll`的高效性和`Reactor`模式,该模式包括一个分发器和多个处理器,用于处理连接和读写事件。Redis采用单线程模型结合`epoll`的Reactor模式,确保高性能。在Redis 6.0后引入多线程,但基本原理保持不变。
64 2
|
6月前
|
Java 调度
Java一分钟之线程池:ExecutorService与Future
【5月更文挑战第12天】Java并发编程中,`ExecutorService`和`Future`是关键组件,简化多线程并提供异步执行能力。`ExecutorService`是线程池接口,用于提交任务到线程池,如`ThreadPoolExecutor`和`ScheduledThreadPoolExecutor`。通过`submit()`提交任务并返回`Future`对象,可检查任务状态、获取结果或取消任务。注意处理`ExecutionException`和避免无限等待。实战示例展示了如何异步执行任务并获取结果。理解这些概念对提升并发性能至关重要。
111 5