当前位置： 首页 > news >正文

Java IO流（三）线程模型

news 2026/2/8 15:00:53

传统阻塞I/O模式

其中黄色框表示对象,蓝色框表示线程,白色框表示API方法

特点

  • 采用阻塞IO模式获取输入数据
  • 每个连接都需要独立的线程完成数据的输入,业务处理和处理结果数据返回

潜在问题

  • 并发数很大时,需要对应每个连接请求创建一个线程,所以占用资源很大
  • 连接创建后,若当前下线程暂时没有数据操作时,该线程会在操作方法处阻塞,造成线程资源浪费

Reactor模式(Dispatch模式)

针对传统阻塞I/O模式的潜在问题,解决方案如下

  • 基于I/O复用模型解决创建线程数量多的问题：通过一个阻塞对象管理所有连接
  • 基于线程池解决线程资源浪费问题

Reactor模式的设计思想就是I/O复用结合下线程池。

核心组成

  • Reator：Reactor在一个单独的thread中运行,负责监听和分发事件,分发给适当的处理程序对IO事件做出反应
  • Handler：真正处理执行Reactor分发过来的IO事件

优势

  • 响应快：不会由于单个同步而导致阻塞
  • 扩展性好：通过方便的增加Reactor实例个数充分利用多核CPU资源
  • 复用性好：Reactor本身与具体的事件处理逻辑无关,具有很高的复用性

根据Reactor的数量和处理资源池线程的数量不同,包括单Reactor单线程、单Reactor多线程和主从Reactor多线程

单Reactor单线程

执行流程

  • Reactor通过Select监控客户端请求事件,收到事件后通过Dispatch进行分发
  • 如果是建立连接请求则由Acceptor处理,并且创建Handler对象处理连接完成后的业务
  • 若不是连接请求(比如read)则分发调用对应的Handler来响应(read->业务处理->send流程)

方案分析

  • 模式简单,没有多线程竞争,全部由一个线程完成
  • 性能问题：仅一个线程,无法发挥多核CPU性能
  • 可靠性问题：线程意外终止或者遇到死循环会导致系统不可用
  • 适用于客户端数量有限,业务处理非常快速的场景

单Reactor多线程

执行流程

  • Reactor通过Select监控客户端请求事件,收到事件后通过Dispatch进行分发
  • 如果是建立连接请求则由Acceptor处理,并且创建Handler对象处理连接完成后的业务
  • 若不是连接请求(比如read)则Reactor分发调用对应的Handler进行响应(read->分发任务->send流程)
  • Handler只负责响应事件,不做具体业务处理,通过read读取数据会分发给work线程池的某个线程处理业务
  • work线程池会分配独立线程完成真正的业务并将结果返回给Handler
  • Handler收到响应后通过send将结果返回给client

方案分析

  • 可以充分利用多核CPU的处理能力
  • 多线程数据共享和访问比较复杂,reactor处理所有的事件的监听和响应,在单线程、高并发场景下容易出现性能瓶颈

主从Reactor多线程(Netty基于此模式)

执行流程

  • Reactor主线程MainReactor对象通过select监听连接事件,若收到连接请求事件则会通过Acceptor处理
  • 当Acceptor处理完成连接事件后,MainReactor将连接分配给SubReactor(一个MainReactor存在多个子Reactor)
  • SubReactor将连接加入到连接队列进行监听,并创建Handler进行对应事件处理
  • 当存在新事件发生时,subReactor就会调用对应Handler处理
  • Handler只负责响应事件,不做具体业务处理,通过read读取数据会分发给work线程池的某个线程处理业务
  • work线程池会分配独立线程完成真正的业务并将结果返回给Handler
  • Handler收到响应后通过send将结果返回给client

方案分析

  • 主线程和子线程数据交互简单职责明确,主线程负责接收连接,子线程完成后续业务处理
  • 主线程和子线程交互简单,主线程把连接交给子线程，子线程无需返回数据
  • 但编程复杂度比较高
  • 应用于Nginx主从Reactor多进程模型、Memcached主从多线程、Netty主从多线程

相关文章：

Java IO流（三）线程模型

传统阻塞I/O模式 其中黄色框表示对象,蓝色框表示线程,白色框表示API方法 特点 采用阻塞IO模式获取输入数据每个连接都需要独立的线程完成数据的输入,业务处理和处理结果数据返回 潜在问题 并发数很大时,需要对应每个连接请求创建一个线程,所以占用资源很大连接创建后,若当前…...

编程日记 2023/8/22 1:58:54

string(模拟实现与深拷贝)

目录 深拷贝与浅拷贝 浅拷贝： 深拷贝 写时拷贝(了解) 模拟实现 准备 完整代码 深拷贝与浅拷贝 浅拷贝： 也称位拷贝，编译器只是将对象中的值拷贝过来。如果对象中管理资源，最后就会导致多个对象共享同一份资源，当一…...

编程日记 2023/8/22 1:57:53

5.Vue_Element

文章目录 1 Ajax1.1 Ajax介绍1.1.1 Ajax概述1.1.2 Ajax作用1.1.3 同步异步 1.2 Axios1.2.1 Axios的基本使用1.2.2 Axios请求方法的别名 2 前端工程化2.1 前端工程化特点2.2 Vue项目开发流程 3 Vue组件库Element3.1 Element介绍 1 Ajax 1.1 Ajax介绍 1.1.1 Ajax概述 Ajax: 全…...

编程日记 2023/8/22 1:56:52

链路追踪jaeger

这里的链路指的是客户端向服务发起一个请求，该请求所经过的路线，也可以说是该请求经过的流量 例如： 客户端发起一个下订单的请求其流量过程： request—>service—>order-web—>order_srv—>mysql—>order_srv—&…...

编程日记 2023/8/22 1:55:51

神经网络基础-神经网络补充概念-42-梯度检验

概念 梯度检验（Gradient Checking）是一种验证数值计算梯度与解析计算梯度之间是否一致的技术，通常用于确保实现的反向传播算法正确性。在深度学习中，通过梯度检验可以帮助验证你的神经网络模型是否正确地计算了梯度，从…...

编程日记 2023/8/22 1:54:50

＜kernel＞kernel 6.4 USB-之-hub_port_connect()分析

＜kernel＞kernel 6.4 USB-之-hub_port_connect()分析 kernel 6.4 USB系列文章如下： ＜kernel＞kernel 6.4 USB-之-hub_event()分析 ＜kernel＞kernel 6.4 USB-之-port_event()分析 ＜kern…...

编程日记 2023/8/22 1:53:48

linux驱动学习3-外部中断

在做中断试验时，发现中断驱动总是insmod失败，之后定位到 gpio_request 失败，之后是想到使用的野火做好的系统，在uEnv.txt中会加载大量设备树插件，将key相关的设备树插件屏蔽即可。 linux中断API函数 中断号 每个中断…...

编程日记 2023/8/22 1:52:47

vue中的canvas插件

vue中canvas插件有vue-konva、vue-fabricjs、vue-canvas-effect、vue-chartjs和vue-threejs等。详细介绍：1、vue-konva是一个用于在Vue.js中使用Konva.js的插件，Konva.js是一个功能强大的HTML5 2D 渲染引擎，可以用于创建交互式的Canvas应用程…...

编程日记 2023/8/22 1:51:45

分享图片 | 快速浏览网页资源，批量保存、一键分享图片

前言 小伙伴学习吉他，有时需要在互联网搜索曲谱资源，而多数曲谱均为图片，并且为多页，在电脑上显示练习很不方便，需要停下来点击鼠标进行翻页，影响练习的连贯性。 为了解决上述问题，通常把图片…...

编程日记 2023/8/22 1:50:44

Programming abstractions in C阅读笔记：p123-p126

《Programming Abstractions In C》学习第50天，p123-p126，总结如下： 一、技术总结 1.notaion 这也是一个在计算机相关书籍中出现的词，但有时却不是那么好理解，因为它可以指代很多对象，这里做一个记录。示…...

编程日记 2023/8/22 1:49:43

自然语言处理从入门到应用——LangChain：链（Chains）-[通用功能：LLMChain、RouterChain和SequentialChain]

分类目录：《自然语言处理从入门到应用》总目录 LLMChain LLMChain是查询LLM对象最流行的方式之一。它使用提供的输入键值（如果有的话，还包括内存键值）格式化提示模板，将格式化的字符串传递给LLM，并返回LLM…...

编程日记 2023/8/22 1:48:42

ElasticSearch-安装部署全过程

本文已收录于专栏 《中间件合集》 目录 概念说明什么是ElasticSearch什么是Kibana什么是RESTful API 提供服务安装过程安装ElasticSearch1.下载ElasticSearch 安装包2.解压安装包3.进入解压之后的文件夹4.创建一个data文件夹用来存储数据5.进入config文件夹编辑elasticsearch.y…...

编程日记 2023/8/22 1:47:39

mathematica报错：Tag Plus is \ Protected

在使用化简函数Simplify的时候使用了规则的语法，但是规则可能没有使用等号。 例如 Simplify[(1 - c^2)/d^2, c^2 d^2 1]等号被认为是赋值符号，要修改为两个等号： Simplify[(1 - c^2)/d^2, c^2 d^2 1]这样就不会报错了。...

编程日记 2023/8/22 1:46:38

Python Django 模型概述与应用

今天来为大家介绍 Django 框架的模型部分，模型是真实数据的简单明确的描述，它包含了储存的数据所必要的字段和行为，Django 遵循 DRY Principle 。它的目标是你只需要定义数据模型，然后其它的杂七杂八代码你都不用关心，…...

编程日记 2023/8/22 1:45:37

Golang Gorm 更新字段 save update updates

更新和删除操作的前提条件都是要在找到数据的情况下，先要查询到数据才可以做操作。 更新的前提的先查询到记录，Save保存所有字段，用于单个记录的全字段更新它会保控所有字段，即使零值也会保存。 在更新和删除之前，要利…...

编程日记 2023/8/22 1:44:36

springBoot 配置文件引入 redis 的相关参数说明

在Spring Boot应用中使用Redis作为缓存或数据存储时，可以在应用的配置文件中配置相关参数。下面是常用的Redis配置参数及其说明： spring.redis.host: Redis服务器主机地址，默认为localhost。spring.redis.port: Redis服务器端口，…...

编程日记 2023/8/22 1:43:35

Docker的使用心得：简化开发与部署的利器

开发与测试的无缝衔接： Docker让开发与测试之间的切换变得前所未有的顺畅。我可以在本地开发环境中创建一个与生产环境一致的Docker容器，这样不仅可以确保开发过程中不会出现意外问题，还可以在测试阶段避免不必要的繁琐配置。 跨平台的可移植…...

编程日记 2023/8/22 1:42:34

vue3 基于element plus对el-pagination进行二次封装

vue3 基于element plus对el-pagination进行二次封装 1、前言2、在components文件夹中新建pagination.vue文件3、在组件内使用分页 1、前言 在vue3项目中，如果每个列表页都敲一遍分页方法，显然是不合理的，那么，下面我将基于elemen…...

编程日记 2023/8/22 1:41:32

RuntimeError: result type Float can‘t be cast to the desired output type __int64报错解决方法

小白刚开始学习YOLOv5，跟随老哥的步骤走了一遍目标检测--手把手教你搭建自己的YOLOv5目标检测平台 最后训练最后一步出现RuntimeError: result type Float can‘t be cast to the desired output type __int64报错 解决方法：找到5.0版报错的loss.py中最…...

编程日记 2023/8/22 1:40:31

解析Python爬虫常见异常及处理方法

作为专业爬虫程序猿长期混迹于爬虫ip解决方案中，我们经常会遇到各种各样的异常情况。在爬虫开发过程中，处理这些异常是不可或缺的一部分。本文将为大家总结常见的Python爬虫异常，并分享相应的处理方法，帮助你避免绊倒在爬虫之路上…...

编程日记 2023/8/22 1:39:29

SCAU期末笔记 - 数据分析与数据挖掘题库解析

这门怎么题库答案不全啊日 来简单学一下子来 一、选择题（可多选） 将原始数据进行集成、变换、维度规约、数值规约是在以下哪个步骤的任务?(C) A. 频繁模式挖掘 B.分类和预测 C.数据预处理 D.数据流挖掘 A. 频繁模式挖掘：专注于发现数据中…...

编程新知 2026/1/24 14:15:43

2.Vue编写一个app

1.src中重要的组成 1.1main.ts // 引入createApp用于创建应用 import { createApp } from "vue"; // 引用App根组件 import App from ./App.vue;createApp(App).mount(#app)1.2 App.vue 其中要写三种标签 <template> <!--html--> </template>…...

编程新知 2026/1/31 6:04:01

TRS收益互换：跨境资本流动的金融创新工具与系统化解决方案

一、TRS收益互换的本质与业务逻辑 &#xff08;一&#xff09;概念解析 TRS&#xff08;Total Return Swap&#xff09;收益互换是一种金融衍生工具&#xff0c;指交易双方约定在未来一定期限内&#xff0c;基于特定资产或指数的表现进行现金流交换的协议。其核心特征包括&am…...

编程新知 2025/11/2 0:31:23

相机Camera日志分析之三十一：高通Camx HAL十种流程基础分析关键字汇总（后续持续更新中）

【关注我，后续持续新增专题博文，谢谢！！！】 上一篇我们讲了：有对最普通的场景进行各个日志注释讲解，但相机场景太多，日志差异也巨大。后面将展示各种场景下的日志。 通过notepad++打开场景下的日志，通过下列分类关键字搜索，即可清晰的分析不同场景的相机运行流程差异…...

编程新知 2025/11/20 7:13:43

【HTTP三个基础问题】

面试官您好&#xff01;HTTP是超文本传输协议&#xff0c;是互联网上客户端和服务器之间传输超文本数据&#xff08;比如文字、图片、音频、视频等&#xff09;的核心协议&#xff0c;当前互联网应用最广泛的版本是HTTP1.1&#xff0c;它基于经典的C/S模型&#xff0c;也就是客…...

编程新知 2025/12/10 6:18:55

在WSL2的Ubuntu镜像中安装Docker

Docker官网链接: https://docs.docker.com/engine/install/ubuntu/ 1、运行以下命令卸载所有冲突的软件包&#xff1a; for pkg in docker.io docker-doc docker-compose docker-compose-v2 podman-docker containerd runc; do sudo apt-get remove $pkg; done2、设置Docker…...

编程新知 2026/2/4 16:23:56

学习STC51单片机32（芯片为STC89C52RCRC）OLED显示屏2

每日一言 今天的每一份坚持&#xff0c;都是在为未来积攒底气。 案例&#xff1a;OLED显示一个A 这边观察到一个点&#xff0c;怎么雪花了就是都是乱七八糟的占满了屏幕。。 解释 &#xff1a; 如果代码里信号切换太快&#xff08;比如 SDA 刚变&#xff0c;SCL 立刻变&#…...

编程新知 2026/2/6 0:50:24

Hive 存储格式深度解析：从 TextFile 到 ORC，如何选对数据存储方案？

在大数据处理领域&#xff0c;Hive 作为 Hadoop 生态中重要的数据仓库工具&#xff0c;其存储格式的选择直接影响数据存储成本、查询效率和计算资源消耗。面对 TextFile、SequenceFile、Parquet、RCFile、ORC 等多种存储格式&#xff0c;很多开发者常常陷入选择困境。本文将从底…...

编程新知 2025/12/6 10:54:35

【网络安全】开源系统getshell漏洞挖掘

审计过程&#xff1a; 在入口文件admin/index.php中&#xff1a; 用户可以通过m,c,a等参数控制加载的文件和方法&#xff0c;在app/system/entrance.php中存在重点代码&#xff1a; 当M_TYPE system并且M_MODULE include时&#xff0c;会设置常量PATH_OWN_FILE为PATH_APP.M_T…...

编程新知 2026/1/31 2:59:25

wpf在image控件上快速显示内存图像

wpf在image控件上快速显示内存图像https://www.cnblogs.com/haodafeng/p/10431387.html 如果你在寻找能够快速在image控件刷新大图像&#xff08;比如分辨率3000*3000的图像&#xff09;的办法&#xff0c;尤其是想把内存中的裸数据&#xff08;只有图像的数据&#xff0c;不包…...

编程新知 2026/1/31 9:25:11