Java多线程(三)——手动实现Future模式

2024-08-24 06:48

本文主要是介绍Java多线程(三)——手动实现Future模式,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在上一章节中向大家介绍了Java为我们提供的Future工具,为了深入了解此模式,本章节将带大家手动来实现future模式。

future模式:使用多线程的目的是为了充分利用计算机资源,来减少处理时间,这必然导致多线程的执行是异步的。然而很多场景下我们需要得到线程执行结果,那么如何来实现呢?future模式提供给我们一种方案,即客户端发送请求,服务端线程启动后就直接返回结果data(并没有真正的结果数据),等服务端处理完成后将线程执行结果放到结果data中,这样客户端即可获取线程执行结果。

  • 序列图:

这里写图片描述

如果大家感觉这么描述还不够清晰,那么让我们看下到底是如何实现的吧!

  • 首先,我们需要一个Data类来存放线程执行返回的结果:
public class Data<T> {//存储结果数据private T data;//结果是否已经准备好private boolean isReady = false;public synchronized T getData() {if (!isReady) {//结果还没获取到try {this.wait();//等待获取结果} catch (InterruptedException e) {          e.printStackTrace();}}return data;}public synchronized void setData(T data) {if(isReady)//已经设置了结果数据return;this.data = data;this.isReady = true;this.notifyAll();//通知其他线程执行 即通知客户端获取线程执行结果}
}
  • 实现一个Task类用于表示任务处理:
 public abstract class Task<T>{ public abstract  T call();
}
import java.util.Random;public class SumTask extends Task<Integer>{@Overridepublic Integer call() {System.out.println("部门:"+ Thread.currentThread().getId()+"正在计算工资");Random random = new Random();try {Thread.sleep(2000);} catch (InterruptedException e) {          e.printStackTrace();}//模拟工资计算耗时Integer sum = random.nextInt(100000);System.out.println("部门:"+ Thread.currentThread().getId()+"计算完成。结果:"+sum);return sum;     }
}
  • 实现一个Service来实现业务的处理:
public class Service<T> implements Runnable{private Task<T> task;private Data<T> data  = new Data<T>();@Overridepublic void run() {T t = task.call();data.setData(t);}public Data<T> submitTask(Task<T> task) {this.task = task;new Thread(this).start();return data;}
}
  • 实现一个Main执行类模拟客户段请求:
public class Main { public static void main(String[] args){long protime = System.currentTimeMillis();Service<Integer> service1 = new Service<>();SumTask task1 = new SumTask();Data<Integer> result1 = service1.submitTask(task1);Service<Integer> service2 = new Service<>();SumTask task2 = new SumTask();Data<Integer> result2 = service2.submitTask(task2);Service<Integer> service3 = new Service<>();SumTask task3 = new SumTask();Data<Integer> result3 = service3.submitTask(task3);Integer sum = 0;sum += result1.getData();sum += result2.getData();sum += result3.getData();               long time = System.currentTimeMillis()-protime;System.out.println("总计需发工资:"+sum+" 耗时:"+time);}
}

执行结果:
这里写图片描述

由结果分析,我们已经实现了future模式,接下来分析下代码中到底做了什么。

  1. 首先Data类负责结果数据的接收,当真实结果数据未接收到的时候用getData方法将使主线程处于等待状态直到接收到真实结果数据。
  2. Task主要是实现了每个部门的工资的结算工作,并返回每个部门的工资总额。
  3. Service通过submitTask接收Task,并执行Task,返回执行结果。可以看到submitTask方法启动一个线程执行Task后,就直接返回一个结果(此时结果并没有真实的结果数据),等线程执行完将结果数据传递到data中,并唤醒其他线程(即Main中result.getData()来实现获取结果数据)。
  4. Main主要是提交任务,接收任务处理结果以及任务耗时和工资结算统计工作。

细心的同学不难发现future模式跟生产者、消费者模式很类似,的确,future模式是生产者、消费者模式的扩展。其实在我们不断学习过程中会慢慢发现,很多看似高深的东西,也都是靠最基础的东西来实现和扩展的,只要基础打牢,在后续的学习将会简单很多。 本片文章到此也要结束了,后续还会对Java多线程方面的知识进行介绍以及总结,谢谢大家的支持!!!(文章中如有描述不明确或不正确的地方,欢迎大家批评指正,谢谢)。

这篇关于Java多线程(三)——手动实现Future模式的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1101757

相关文章

SpringBoot3实现Gzip压缩优化的技术指南

《SpringBoot3实现Gzip压缩优化的技术指南》随着Web应用的用户量和数据量增加,网络带宽和页面加载速度逐渐成为瓶颈,为了减少数据传输量,提高用户体验,我们可以使用Gzip压缩HTTP响应,... 目录1、简述2、配置2.1 添加依赖2.2 配置 Gzip 压缩3、服务端应用4、前端应用4.1 N

Java编译生成多个.class文件的原理和作用

《Java编译生成多个.class文件的原理和作用》作为一名经验丰富的开发者,在Java项目中执行编译后,可能会发现一个.java源文件有时会产生多个.class文件,从技术实现层面详细剖析这一现象... 目录一、内部类机制与.class文件生成成员内部类(常规内部类)局部内部类(方法内部类)匿名内部类二、

SpringBoot实现数据库读写分离的3种方法小结

《SpringBoot实现数据库读写分离的3种方法小结》为了提高系统的读写性能和可用性,读写分离是一种经典的数据库架构模式,在SpringBoot应用中,有多种方式可以实现数据库读写分离,本文将介绍三... 目录一、数据库读写分离概述二、方案一:基于AbstractRoutingDataSource实现动态

Python FastAPI+Celery+RabbitMQ实现分布式图片水印处理系统

《PythonFastAPI+Celery+RabbitMQ实现分布式图片水印处理系统》这篇文章主要为大家详细介绍了PythonFastAPI如何结合Celery以及RabbitMQ实现简单的分布式... 实现思路FastAPI 服务器Celery 任务队列RabbitMQ 作为消息代理定时任务处理完整

Linux系统配置NAT网络模式的详细步骤(附图文)

《Linux系统配置NAT网络模式的详细步骤(附图文)》本文详细指导如何在VMware环境下配置NAT网络模式,包括设置主机和虚拟机的IP地址、网关,以及针对Linux和Windows系统的具体步骤,... 目录一、配置NAT网络模式二、设置虚拟机交换机网关2.1 打开虚拟机2.2 管理员授权2.3 设置子

Springboot @Autowired和@Resource的区别解析

《Springboot@Autowired和@Resource的区别解析》@Resource是JDK提供的注解,只是Spring在实现上提供了这个注解的功能支持,本文给大家介绍Springboot@... 目录【一】定义【1】@Autowired【2】@Resource【二】区别【1】包含的属性不同【2】@

springboot循环依赖问题案例代码及解决办法

《springboot循环依赖问题案例代码及解决办法》在SpringBoot中,如果两个或多个Bean之间存在循环依赖(即BeanA依赖BeanB,而BeanB又依赖BeanA),会导致Spring的... 目录1. 什么是循环依赖?2. 循环依赖的场景案例3. 解决循环依赖的常见方法方法 1:使用 @La

Java枚举类实现Key-Value映射的多种实现方式

《Java枚举类实现Key-Value映射的多种实现方式》在Java开发中,枚举(Enum)是一种特殊的类,本文将详细介绍Java枚举类实现key-value映射的多种方式,有需要的小伙伴可以根据需要... 目录前言一、基础实现方式1.1 为枚举添加属性和构造方法二、http://www.cppcns.co

使用Python实现快速搭建本地HTTP服务器

《使用Python实现快速搭建本地HTTP服务器》:本文主要介绍如何使用Python快速搭建本地HTTP服务器,轻松实现一键HTTP文件共享,同时结合二维码技术,让访问更简单,感兴趣的小伙伴可以了... 目录1. 概述2. 快速搭建 HTTP 文件共享服务2.1 核心思路2.2 代码实现2.3 代码解读3.

Elasticsearch 在 Java 中的使用教程

《Elasticsearch在Java中的使用教程》Elasticsearch是一个分布式搜索和分析引擎,基于ApacheLucene构建,能够实现实时数据的存储、搜索、和分析,它广泛应用于全文... 目录1. Elasticsearch 简介2. 环境准备2.1 安装 Elasticsearch2.2 J