java多线程Thread-per-Message模式详解
作者:小明是个程序猿 发布时间:2022-12-23 16:55:00
Thread-per-Message模式(这项工作就交给你了)
当你很忙碌的时候,这个时候公司楼下有个快递,于是你委托你的同事帮你拿一下你的快递,这样你就可以继续做自己的工作了
在Thread-Per-Message模式中,消息的委托端和执行端是不同的线程,消息的委托端会告诉执行端线程,这个工作就交给你了
Host类:
针对请求创建线程的类,主要通过开启新的线程,调用helper的handle,并将要打印的文字传递。
public class Host {
private final Helper helper = new Helper();
public void request(final int count,final char c){
System.out.println("request开始");
new Thread(){
public void run(){
helper.handle(count, c);
}
}.start();
System.out.println("request结束");
}
}
Helper类:
提供字符显示的功能,slowly方法模拟打印耗时
public class Helper {
public void handle(int count ,char c){
System.out.println("handle方法开始");
for(int i=0;i<count;i++){
slowly();
System.out.print(c);
}
System.out.println("");
System.out.println("handle方法结束");
}
private void slowly(){
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
Main类:
创建Host的实例,并调用request的方法
public static void main(String[] args) {
System.out.println("main begin");
Host host = new Host();
host.request(10, 'A');
host.request(20, 'B');
host.request(30, 'C');
System.out.println("main End");
}
测试结果:
main begin
request方法开始了
request方法结束
request方法开始了
request方法结束
request方法开始了
request方法结束
main End
handle方法开始
handle方法开始
handle方法开始
BACBACACBACBACBACBACBACBACBA
handle方法结束
CBCBCBCBCBCBCBCBCBCBCB
handle方法结束
CCCCCCCCCC
handle方法结束
从运行的结果可以看出,request方法,并没有等待handle方法执行结束后再执行,而是调用handle方法后就返回到request方法中,直到运行结束,所以相当于request方法将所要进行的打印一定数量字符的工作转交给了handle方法,而request方法则可以再执行笨方法中的其他的语句,不必等待handle方法完成。这也同时告诉我们,当某些工作比较耗时时,则可以通过这种模式启动新的线程来执行处理。可以将此模式应用于服务器,这样就可以减少服务器的响应时间。
讲解一下进程和线程:
线程和进程最大的区别就是内存是否共存。
每个进程有自己的独立的内存空间,一个进程不可以擅自读取和写入其他的进程的内存,由于进程的内存空间是彼此独立的,所以一个进程无需担心被其他的进程所破坏。
线程之间是可以共存的,一个线程向实例中写入内容,其他线程就可以读取该实例的内容,由于多个线程可以访问同一个实例,我们就需要保证其正确执行互斥处理。
Host设计优化:
1.使用java.util.concurrent包下的ThreadFactory接口设计Host类
public class Host {
public void request(final int count,final char c){
System.out.println("request方法开始了");
threadFactory.newThread(
new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
helper.handle(count, c);
}
}
).start();;
System.out.println("request方法结束");
}
}
对应的Host实例化对象:
Host host = new Host(Executors.defaultThreadFactory());
这样设计的优势在于,原来的使用new创建的实例代码依赖于java.lang.Thread类,无法控制创建线程的部分,可复用性较低,假如使用threadFactory来保存对应类的对象,调用newThread方法创建新的线程,这样便实现了线程的创建,这样不再依赖于Thread类,而是取决于构造函数中传入的ThreadFactory对象,实现了控制线程创建的细节。
使用java.util.concurrent.Executor接口重新设计Host类:
前面的ThreadFactory接口隐藏了线程创建的细节,但是并未隐藏线程创建的操作,如果使用Executor接口,那么线程创建的操作也会被隐藏起来
public class Host{
private final Helper helper = new Helper();
private final Executor executor;
public Host(Executor executor){
this.executor = executor;
}
public void request(final int count,final char c){
System.out.println("request方法开始了");
executor.execute(new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
helper.handle(count, c);
}
});
System.out.println("request方法结束");
}
}
使用java.util.concurrent.ScheduledExecutorService类创建,其可以实现调度运行
public class Host{
private final Helper helper = new Helper();
private final ScheduledExecutorService scheduledExecutorService;
public Host(ScheduledExecutorService scheduledExecutorService){
this.scheduledExecutorService = scheduledExecutorService;
}
public void request(final int count,final char c){
System.out.println("request方法开始了");
scheduledExecutorService.schedule(new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
helper.handle(count, c);
}
}, 3L, TimeUnit.SECONDS);
System.out.println("request方法结束");
}
}
测试主函数入口:
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5);
Host host = new Host(
scheduledExecutorService
);
try {
host.request(10, 'A');
host.request(20, 'B');
host.request(30, 'C');
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
scheduledExecutorService.shutdown();
System.out.println("main End");
}
总结
Client 角色调用Host角色的request方法发来的请求,该请求的实际处理则交给Helper的handle去执行,然而,如果Client直接从request中调用handle方法,那么直到实际操作结束之前,都无法从handle方法返回(request返回),这样一来request的响应性能就下降了,因此,Host角色会启动用于处理来自Client角色请求的新线程,并让该线程来调用handle,这样一来发出请求的线程便可以立即从handle中返回。这就是Thread-Per-Message模式。
来源:https://blog.csdn.net/qq_31350373/article/details/80454306
猜你喜欢
- classpath读取resources目录下文件最近在springboot+maven的项目中去读取资源文件的时候,报了找不到文件的错误。
- 1. 前言今天开始我们来一步步窥探它是如何工作的。我们又该如何驾驭它。本篇将通过 Spring Boot 2.x 来讲解 Spring Se
- 操作步骤如下一、dropzone导入01.dropzone官网下载其插件压缩包并复制项目;02.将CSS和JS文件在HTML文件中引入;//
- 图片上传功能是我们web里面经常用到的,获得的方式也有很多种,这里我用的是request.getInputStream()获取文件流的方式。
- windows应用程序(包括控制台)在运行时如果出现了未处理的异常会出项windows的异常提示框 &nb
- 主要完成任务:1.read read 并行化2.read write 不允许3.write write 不允许public class Re
- 在谈 JVM 内存区域划分之前,我们先来看一下 Java 程序的具体执行过程,我画了一幅图。Java 源代码文件经过编译器编译后生成字节码文
- 面试题1:你了解线程池么?简单介绍一下。java提供的一个java.util.concurrent.Executor接口的实现用于创建线程池
- 在有些需求中会遇到,当鼠标滑过某个UI物体上方时,为了提醒用户该物体是可以交互时,我们需要添加一个动效和提示音。这样可以提高产品的体验感。解
- 引言在实际分布式项目中延迟任务一般不会使用JDK自带的延迟队列,因为它是基于JVM内存存储,没有持久化操作,所以当服务重启后就会丢失任务。在
- Redisson是架设在redis基础上的一个Java驻内存数据网格(In-Memory Data Grid)。充分的利用了Redis键值数
- 最近因为fastjson安全漏洞,升级jar包时,踩了一些坑。新版本FastJsonHttpMessageConverter初始化,默认设置
- BufferedImage转换为MultipartFileJava里读取图片或调整图片大小可使用BufferedImage进行操作(参考我另
- 页面代码:<%@ page language="java" contentType="text/html
- 一、setting.xml文件的位置今天我们来谈谈Maven setting文件配置的禅定之道。不知道大家有没有听说过禅宗?嗯,没错,就是那
- 背景最近项目中需要上传视频文件,由于视频文件可能会比较大,但是我们应用服务器tomcat设置单次只支持的100M,因此决定开发一个分片上传接
- 本文实例为大家分享了java利用数组随机抽取幸运观众的具体代码,供大家参考,具体内容如下思想:首先将所有观众姓名生成数组,然后获取数组元素的
- 一.搭建1.前端npm installnpm run serve2.后端老生常谈的配置,修改mysql与redis即可。二.业务功能介绍功能
- 前言SPI 全称为 Service Provider Interface,是一种服务发现机制。SPI 的本质是将接口实现类的全限定名配置在文
- 算法中递归的一个典型应用就是遍历目标文件夹,并把该文件夹下的所有文件和文件夹打印或显示出来,还可以递归计算出目标文件夹的总大小。本文即以实例