【Java ee初阶】多线程（6）
一、阻塞队列
队列的原则：“先进先出”，队列分为普通队列，优先级队列等等。在数据结构中，堆是特殊的完全二叉树，一定不要把堆和二叉搜索树混淆。
阻塞队列是一种特殊的队列，也遵循“先进先出”的原则。
阻塞队列的特点：1.线程安全
2.带有阻塞功能
（1）如果队列为空，尝试出队列，就会触发阻塞，直到队列不空
（2）如果队列满了，尝试入队列，也会触发阻塞，直到队列不满
*生产者消费模型
引入生产者消费模型，主要目的是为了减少“锁竞争”，生产者和消费者的步调，不一定完全一致。出现不一样的时候阻塞队列可以起到"协调"的作用。
阻塞队列，用于协调多个线程之间的工作。
生产者消费模型，是后端开发中，常见的编程手段。
*什么是耦合
目前，大多数公司采用的是分布式系统。“服务器开发”，开发的不是一个服务器程序，通常是一组服务器程序，一台机器搞不定，需要多台机器。
例如：
此时A B C之间是直接调用的关系，因此他们之间的耦合关系就比较大
如果C这个模块修改了，B这个模块就可能也要配合修改
如果要增加一个D，那么也要针对B进行需修改
于是，我们可以在B和C之间加上一个阻塞队列（消息队列MQ）
这样子，如果C产生变动，对于B的影响就非常小了。如果再增加D，那么对于B影响很小。
但是，这样子做也是有代价的，首先，系统结构就更加复杂了，而且网络通信的效率会变得更低。
优点如下：
1、减少资源竞争，提高效率
2、可以更好地做到模块之间的解耦合
3、削峰填谷
A收到多大的压力，此时BCD收到的压力是相同的（此处的压力指的是每秒钟需要处理的请求数目），一旦BCD中某个机器顶不住了，此时整个系统可能就崩溃了
此时，A收到的压力，只是传递给B。而CD则被MQ保护起来了。每个服务器完成的功能不同，有的服务器处理一个请求，消耗的资源更多，有的就更少。
这种单个请求消耗资源较多的服务器，就更容易挂掉（MySQL服务器，就属于是比较脆弱的，容易挂掉的）
一个服务器为什么会挂？因为一个服务器每次处理一个请求，都是要消耗一定的硬件资源的，包括但不限于cpu，内存，硬盘，网络宽带
一个机器，能够提供的硬件资源，是有上限的，同一时刻，如果请求太多了，消耗的总资源超出机器能够提供的资源的上限，那么整个时候机器就会挂机了（系统也就无法进行访问了）
生产者消费者模型：
优点：
1.减少资源竞争，提升效率
2.降低耦合
3.削峰填谷
缺点：
1.系统更加复杂
2.引入队列的层数太多，就会增加网络开销
二、BlockingQueue
针对BlockingQueue，offer / add 等方法，是不带有“阻塞功能”的。
多个线程交互
三、实现阻塞队列
package Thread;
//自己基于以前学过的知识，写一个阻塞队列class MyBlockingQueue{ // 阻塞队列。private String[] array = null;private int size = 0; // 队列的大小。private int head = 0; // 队列的头指针。private int tail = 0; // 队列的尾指针private Object locker = new Object(); // 锁对象，用于保证线程安全。public MyBlockingQueue(int capacity){ // 构造方法，初始化队列的大小。array = new String[capacity]; // 队列的数组。}public void put(String element) throws InterruptedException { synchronized(locker){// 入队列。if(size >= array.length){locker.wait(); // 队列已满，等待。}array[tail] = element; // 入队列。tail++; // 尾指针加1。if(tail >= array.length){ // 如果尾指针超过了数组的长度，就从头开始。tail = 0; // 尾指针回到0。}size++; // 队列的大小加1。locker.notify(); // 唤醒等待的线程。}}public String take() throws InterruptedException { // 出队列。synchronized(locker){ // 出队列。if (size==0) {locker.wait(); // 队列已空，等待。}String element = array[head]; // 出队列。head++; // 头指针加1。if(head >= array.length){ // 如果头指针超过了数组的长度，就从头开始。head = 0; // 头指针回到0。}size--; // 队列的大小减1。locker.notify(); // 唤醒等待的线程。return element; // 返回出队列的元素。}
}
}
public class demo37 {public static void main(String[] args) {MyBlockingQueue myBlockingQueue = new MyBlockingQueue(1000); // 创建一个阻塞队列。Thread producer = new Thread(() -> { // 创建一个生产者线程。int count = 0; // 计数器，用于记录生产的数量。try { // 捕获异常。while (true) { // 无限循环，一直生产。myBlockingQueue.put(" " + count); // 入队列。System.out.println("生产了一个元素：" + count); // 打印出生产的元素。count++; // 计数器加1。Thread.sleep(1000); // 生产者休眠 0.5 秒。} }catch (Exception e) {e.printStackTrace(); // 打印异常信息。}
});Thread consumer = new Thread(() -> { // 创建一个消费者线程。try { // 捕获异常。while (true) { // 无限循环，一直消费。String take = myBlockingQueue.take(); // 出队列。System.out.println("消耗了一个元素：" + take); // 打印出队列的元素。Thread.sleep(1000); // 消费者休眠 1.5 秒。}}catch (Exception e) {e.printStackTrace(); // 打印异常信息。}});producer.start(); // 启动生产者线程。consumer.start(); // 启动消费者线程。try { // 捕获异常。producer.join(); // 等待消费者线程结束。consumer.join(); // 等待生产者线程结束。} catch (InterruptedException e) { // 捕获异常。e.printStackTrace(); // 打印异常信息。}}
}
最终输出：
官方文档上建议用while来写
为什么此处要用while而不是if呢？
因为，进入wait之前，当然要判定一次条件，写作while当wait被唤醒之后，还需要再次判定一次条件。
正常来说，肯定得是条件被打破了才能唤醒，此处条件是size>=length，必然是有其他线程take,size就会<length，触发notify
如果是其他代码，不排除出现，唤醒之后条件仍然成立的可能性。
确定好条件确实是不成立了，然后再继续往下走，相当于“二次确认”的效果。
相关文章：
【Java ee初阶】多线程（6）
一、阻塞队列 队列的原则：“先进先出”，队列分为普通队列，优先级队列等等。在数据结构中，堆是特殊的完全二叉树，一定不要把堆和二叉搜索树混淆。 阻塞队列是一种特殊的队列，也遵循“先进先出”的原则。 …...
Unity：Surface Effector 2D（表面效应器 2D）
目录 什么是表面效应器 2D？ 🎯 它是做什么的？ 🧪 从第一性原理解释它是怎么工作的 📦 重要参数解释 为什么不直接用 Rigidbody（刚体）来控制运动 ？ 所以什么时候该用哪个&#…...
Spring 框架的底层原理
Spring 框架的底层原理主要包括以下几个方面： 核心容器（IoC 容器） IoC（控制反转）原理 ： 依赖注入（DI） ：这是 IoC 的实现方式之一。在传统的程序开发中，程序组…...
【Unity】AssetBundle热更新
1.新建两个预制体： Cube1：GameObject Material1：Material Cube1使用了Material1材质 之后设置打包配置 Cube1的打包配置为custom.ab Material1的打包配置为mat.ab 2.在Asset文件夹下创建Editor文件夹，并在Editor下创建BuildBundle…...
【算法笔记】动态规划基础（二）：背包dp
目录 01背包例题状态表示状态计算初始化AC代码 完全背包例题状态表示状态计算初始化TLE代码 多重背包例题状态表示状态计算初始化AC代码 分组背包例题状态表示状态计算初始化AC代码 二维费用背包例题状态表示状态计算初始化AC代码 混合背包问题例题状态表示状态计算初始化TLE代…...
IP属地是我的定位吗？——解析两者区别
在互联网时代，我们经常看到社交媒体、论坛或APP上显示用户的“IP属地”，许多人会疑惑：IP属地是不是我的精确定位？它会不会暴露我的隐私？ 本文将详细解析IP属地和定位的区别，并解答常见的相关问题&#…...
力扣每日一题1128等价多米诺骨牌对的数量
1128. 等价多米诺骨牌对的数量 题目： 给你一组多米诺骨牌 dominoes 。 形式上，dominoes[i] [a, b] 与 dominoes[j] [c, d] 等价 当且仅当 (a c 且 b d) 或者 (a d 且 b c) 。即一张骨牌可以通过旋转 0 度或 180 度得到另一张多米诺骨牌。 在 0 &l…...
SpringBoot集成CXF框架，实现WebService
SpringBoot官网地址：https://spring.io/projects/spring-ws 1、WebService服务端搭建 Maven依赖 <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.7.17&…...
: macOS 安装 ndk)
android-ndk开发(2): macOS 安装 ndk
android-ndk开发(2): macOS 安装 ndk 2025/05/05 1. 概要 对于 android-ndk 在 r23 之前的版本，官方提供了 .zip 文件， 解压即安装。 对于 android-ndk 在 r23 以及之后的版本， 官方只提供了 .dmg 文件， 不能简单的解压完成安…...
科创大赛——知识点复习【c++】——第一篇
目录 输入 一、cin 二、scanf 三、gets 四、getchar 五、fgets 输出 一、cout 二、printf 基本数据类型 一，数据类型有哪些？ 二，整型（Integer Types） 1，修饰符 2，整型数据的数据范…...
硬件工程师面试常见问题（14）
第六十六问：运放--输入偏置电流和输入失调电流 输入偏置电流lb：是由于运放两个输入极都有漏电流的存在。实际的运放,会有电流流入运放的输入端的。那么输入偏置电流就定义这两个电流的平均值。 输入失调电流 Ios：定义为两个差分输入端偏置电…...
Flink流水线任务在线演示
Flink流水线在线演示 1. 登录系统 访问系统登录页面，输入账号密码完成身份验证。 2. 创建任务 入口：通过顶部菜单栏选择 任务开发，或通过快捷入口 快速创建任务。 任务类型：选择 FlinkPipeline。 3. 配置任务 进入配置界面…...
C++笔记之接口`Interface`
C++笔记之接口Interface code review! 一个简洁简短的 C++ 接口实现示例： #include <iostream>// 1. 定义接口（抽象类） class Shape {public:...
css使用aspect-ratio制作4:3和9:16和1:1等等比例布局
文章目录 1. 前言2. 用法2.1 基本语法2.2. 与max-width、max-height等属性结合使用2.3. 动态计算比例 3. 应用场景4. 兼容性和替代方案5. 总结 1. 前言 在网页制作过程中，有时候我们只知道宽度，或者只知道高度，这时候需要制作一个4:3和9:16这…...
深入探索 Apache Spark：从初识到集群运行原理
深入探索 Apache Spark：从初识到集群运行原理 在当今大数据时代，数据如同奔涌的河流，蕴藏着巨大的价值。如何高效地处理和分析这些海量数据，成为各行各业关注的焦点。Apache Spark 正是为此而生的强大引擎，它以其卓越…...
0903Redux改造项目_用户信息_状态管理-react-仿低代码平台项目
文章目录 1 Redux管理用户信息1.1 定义store和reducer1.2 使用useSeletor 2 自定义Hook统一加载用户信息存储Redux3 根据用户登录状态动态跳转页面结语 1 Redux管理用户信息 1.1 定义store和reducer src/store/userReducer.ts代码如下所示： import { createSlice…...
PyTorch_构建线性回归
使用 PyTorch 的 API 来手动构建一个线性回归的假设函数，数据加载器，损失函数，优化方法，绘制训练过程中的损失变化。 数据构建 import torch from sklearn.datasets import make_regression import matplotlib.pyplot as plt i…...
领略算法真谛: 多源bfs
嘿，各位技术潮人！好久不见甚是想念。生活就像一场奇妙冒险，而编程就是那把超酷的万能钥匙。此刻，阳光洒在键盘上，灵感在指尖跳跃，让我们抛开一切束缚，给平淡日子加点料，注入满满的pa…...
Linux的web服务器的部署及优化
实验环境的配置 我们依然是要配置本地软件仓库，之前已有详细介绍，然后再次基础上还有如下操作，首先是进入到以下文件进行编辑 编辑内容为下，并且注意自身的网关有没有写错 然后给予权限 再进行下列操作后，就配置完成了…...
ASP.NET Core 请求限速的ActionFilter
文章目录 前言一、实现步骤1）创建自定义Action Filter示例1：示例2： 2）注册服务3）使用 二、实现说明总结 前言 以下是一个基于内存缓存实现的自定义限流Action Filter。 一、实现步骤 1）创建自定义Action…...
本地化语音转换工具推荐与使用
软件介绍 Buzz是一款基于OpenAI Whisper技术开发的开源语音转文字工具，支持离线运行和实时语音转换，能够高效完成会议记录、音频转文字等任务。 安装注意事项 在使用Buzz之前需要注意软件的安装设置，由于程序自带较大的模型文件&…...
【心海资源】telegram换U地址完整源码
【心海资源】telegram换U地址完整源码 未测,需要的下载完整的 下载地址：下载地址.txt - 蓝奏云...
神经网络开发实战：从零基础到企业级应用（含CNN、RNN、BP网络代码详解）
简介 神经网络作为深度学习的核心，正在成为现代AI应用的基石。从基础的感知机到复杂的Transformer架构，从图像识别到自然语言处理，神经网络技术的演进推动了人工智能的快速发展。本文将系统介绍神经网络的核心概念、主流模型及其实现原理，并通过三个企业级实战案例（医学图…...
C# WPF 布局
C# 0、WPF 布局 1、ON/OFF按钮 2、textBox 3、ComboBox 4、TabControl 5、Button <Window x:Class"WpfApp5.MainWindow"xmlns"http://schemas.microsoft.com/winfx/2006/xaml/presentation"xmlns:x"http://schemas.microsoft.com/winfx/20…...
【PaaS与AI融合】MLOps平台的架构设计
PaaS与AI融合：MLOps平台的架构设计 一、技术背景与发展趋势二、技术架构核心特征1. 全生命周期管理闭环2. 混合编排引擎3. 智能资源调度三、关键技术实现细节1. 持续集成流水线2. 异构资源管理3. 安全治理体系四、行业实践与未来演进典型案例分析发展趋势展望五、架构设计建议…...
硬件工程师面试常见问题（15）
第七十一问：运放增益带宽积解读（有待改进） 增益带宽积顾名思义：增益（就是开环增益）与带宽的乘积； 第七十二问：运放输出摆幅 定义：输出摆幅是指输出信号在最大值和最小值…...
SpringMVC——第6章：RESTFul编程风格
一、RESTFul编程风格 1.RESTFul是什么 RESTFul是WEB服务接口的一种设计风格。 RESTFul定义了一组约束条件和规范，可以让WEB服务接口更加简洁、易于理解、易于扩展、安全可靠。 RESTFul对一个WEB服务接口都规定了哪些东西？ 对请求的URL格式有约束和规范…...
深度解析：从 GPT-4o“谄媚”到 Deepseek“物理腔”，透视大模型行为模式的底层逻辑与挑战
深度解析：从 GPT-4o“谄媚”到 AI“物理腔”，透视大模型行为模式的底层逻辑与挑战 标签：人工智能, GPT-4o, 大语言模型, AI伦理, 人机交互, 技术思考 大家好！最近AI圈最火的“瓜”之一，莫过于OpenAI的GPT-4o模型在一…...
2025 年最新树莓派 Pico 连接 OLED 显示字模汉字详细教程
OLED 概述 OLED（Organic Light-Emitting Diode，有机发光二极管）是一种基于有机材料的发光技术，通过电流驱动有机薄膜发光，具有自发光、高对比度、柔性可弯曲等特点。 4 针脚 OLED 硬件电路如图所示，GND 接…...
【Ubuntu 安装Docker CE-Jenkins】
安装Docker CE(Ubuntu) Install | Docker Docs官网 使用apt仓库安装 DNS配置(可选) #手动替换 sudo vim /etc/systemd/resolved.conf #典型配置如下 [Resolve] DNS8.8.8.8 DNS114.114.114.114 FallbackDNS1.1.1.1 # 备用 DNS#sed替换 sudo sed -i /^#DNS/ {s/#DNS/DNS8.8.8…...
知识图谱 + 大语言模型：打造更聪明、更可靠的AI大脑 —— 探索 GraphRAG 中文优化与可视化实践
大语言模型（LLMs）无疑是近年来人工智能领域最耀眼的明星。它们强大的自然语言理解和生成能力，在文本创作、代码生成、对话交互等众多领域展现了惊人的潜力。然而，当前的 LLMs 并非完美无缺，它们常常面临着“幻觉”&…...
三、【LLaMA-Factory实战】模型微调进阶：从LoRA到MoE的技术突破与工程实践
一、引言 在大模型微调领域，选择合适的训练策略直接决定了效率与效果的平衡。LLaMA-Factory深度整合了参数高效微调（PEFT）、全量微调、混合专家模型（MoE）等12种训练策略，支持从消费级GPU到多卡集群的全场景…...
Photo-SLAM论文理解、环境搭建、代码理解与实测效果
前言：第一个解耦式Photo-SLAM，亮点和效果。 参考：https://zhuanlan.zhihu.com/p/715311759 全网最细PhotoSLAM的conda环境配置教程，拒绝环境污染！！-CSDN博客 1. 环境搭建 硬件：RTX 4090D wi…...
解决pycharm检测不到已经装好的conda的pytorch环境
问题 1.找装anaconda的位置（我装到了py-anacon下） 2.找到下图中的conda.bat 3.pycharm社区版右下角，添加新解释器 4.选conda环境，选择2.中conda.bat的位置，加载环境，使用现有环境，可以看到有选…...
【计算机视觉】3d人脸重建：3DDFA_V2：实时高精度3D人脸重建与密集对齐技术指南
3d人脸重建：3DDFA_V2：实时高精度3D人脸重建与密集对齐技术指南 一、项目概述与技术背景1.1 3DDFA_V2核心价值1.2 技术演进路线1.3 核心技术指标 二、环境配置与模型部署2.1 硬件要求2.2 软件安装基础环境搭建关键组件安装 2.3 模型下载 三、核心算法原理…...
谈判模拟器 - Gemini 2.5 商业优化版
核心目标： 基于深厚的理论知识、丰富的实战经验和前沿的技术洞察，结合麦肯锡领先的谈判策略框架，为用户提供全面、深入、可操作的商业谈判策略指导和建议，助力其在复杂商业环境中达成最优谈判结果，并实现商业价值最大化…...
四个基本公式推导)
深度学习系统学习系列【4】之反向传播（BP)四个基本公式推导
文章目录 补充知识：∇ 和 ⊙ 运算符详解∇ (nabla) 运算符⊙ (圆圈点) 运算符 反向传播基本公式计算图和基本定义BP1：输出层误差推导BP1公式的重要性实际例子BP2第 l l l层误差推导BP3 ：损失函数关于偏置(b)偏导的推导BP4： 损失函…...
算法每日一题 | 入门-顺序结构-上学迟到
上学迟到 题目描述 学校和 yyy 的家之间的距离为 s 米，而 yyy 以 v 米每分钟的速度匀速走向学校。 在上学的路上，yyy 还要额外花费 10 分钟的时间进行垃圾分类。 学校要求必须在上午 8:00 到达，请计算在不迟到的前提下，yyy 最…...
开源库测试
yolov10 https://github.com/THU-MIG/yolov10 conda create -n yolov10 python3.9 conda activate yolov10 pip install -r requirements.txt pip install -e .报错 找不到对应版本 Could not find a version that satisfies the requirement gradio4.31.5 (from versions:…...
因为gromacs必须安装cuda（系统自带的NVIDIA驱动不行），这里介绍下如何安装cuda
1. 安装步骤 查看是否安装了cuda # 法1 cat /usr/local/cuda/version.txt # 法2 nvcc --version 若没有安装，则查看是否有N卡驱动，若无N卡驱动，则到软件与更新 -> 附加驱动中安装驱动 查看N卡驱动支持的cuda版本 nvidia-smi 如下…...
ABC 404
1.C 题： 1.思路： NM&每个点读数为2，但图中有可能出现多环，需要判断所有点是否都在同一连通块上，有俩种解法：搜索，循环 2.代码（循环做法） #include<bits/stdc.h&g…...
机器学习朴素贝叶斯算法
1.朴素贝叶斯算法 1.1基本概念 其分类原理是利用贝叶斯公式根据某特征的先验概率计算出其后验概率，然后选择具有最大后验概率作为该特征所属的类。之所以称之为“朴素”，是因为贝叶斯分类只做最原始、最简单的假设：所有的特征之间是相对独立…...
Linux：深入理解数据链路层
实际上一台主机中，报文并没有通过网络层直接发送出去，而是交给了自己的下一层协议——数据链路层！！ 一、理解数据链路层 网络层交付给链路层之前，会先做决策再行动（会先查一下路由表，看看目标网…...
健康养生：从生活点滴启航
养生并非遥不可及的高深学问，只需把握生活中的细微之处，就能为健康保驾护航。 清晨睁眼，先在床上做简单的搓脸动作，从下巴到额头轻柔按摩，促进面部血液循环，唤醒肌肤活力。随后空腹喝一杯温水，可…...
【向量数据库】用披萨点餐解释向量数据库：一个美味的技术类比
文章目录 前言场景设定：披萨特征向量化顾客到来：生成查询向量相似度计算实战1. 欧氏距离计算（值越小越相似）2. 余弦相似度计算（值越大越相似） 关键发现：度量选择影响结果现实启示结语 前言 想象…...
CloudCompare 中 ccDrawableObject
CloudCompare 中 ccDrawableObject 类的主要内容与使用 1. ccDrawableObject 概述 在 CloudCompare 中，ccDrawableObject 是一个基类，主要用于管理 3D 可绘制对象 的显示属性，如颜色、可见性、LOD（层次细节）、光照等…...
【Linux】进程控制
🌟🌟作者主页：ephemerals__ 🌟🌟所属专栏：Linux 目录 前言 一、什么是进程控制 二、进程创建 三、进程终止（进程退出） 退出码 main函数返回 _exit() exit() 测试 四、进…...
设计模式-基础概念学习总结（继承、多态、虚方法、方法重写）
概念使用例子的方式介绍（继承，多态，虚方法，方法重写），实现代码python 1. 继承（Inheritance） 概念：子类继承父类的属性和方法，可以直接复用父类的代码&#…...
和srand()函数的功能)
分析rand()和srand()函数的功能
rand()和srand()函数原型： int rand(void) 返回一个范围在 0 到 RAND_MAX 之间的伪随机数。 void srand(unsigned int seed)用来给rand() 设置随机数发生器，随机数发生器输出不同的数值，rand() 就会生成不同的随机数 1)、在“D:\Keil_v5\AR…...
架构师如何构建个人IP：职业规划与业务战略的双重提升
在数字化时代，软件架构师的角色已从单纯的技术专家转变为兼具技术领导力和业务影响力的复合型人才。如何构建个人IP，提升行业影响力，成为架构师职业发展的关键课题。本文从个人认知、业务战略、架构决策、产品思维四个维度，探讨架…...