java并发之BlockingQueue
种类
| 类名 | 特性 |
|---|---|
| ArrayBlockingQueue | 由数组结构组成的有界阻塞队列 |
| LinkedBlockingQueue | 由链表结构组成的有界的阻塞队列（有界，默认大小 Integer.MAX_VALUE，相当于无界） |
| PriorityBlockingQueue | 支持优先级排序的无界阻塞队列 |
| DelayQueue | 使用优先级队列实现的延迟无界阻塞队列 |
| SynchronousQueue | 不存储元素的阻塞队列，即单个元素的队列，生产一个，消费一个，不存储元素，不消费不生产 |
| LinkedTransferQueue | 由链表结构组成的无界阻塞队列 |
| LinkedBlockingDeque | 由链表结构组成的双向阻塞队列 |
方法
| 常用方法 | 描述 |
|---|---|
| add(E e) | 将指定的元素插入此队列中，如果没有可用的空间，则抛出异常。 |
| offer(E e) | 将指定的元素插入此队列中，如果可以在不违反容量限制的情况下立即执行，则成功返回 true，否则返回 false。 |
| put(E e) | 将指定的元素插入此队列中，如果队列已满，则一直等待直到有空间可用。 |
| remove() | 检索并删除此队列的头部，如果队列为空，则抛出异常。 |
| poll() | 检索并删除此队列的头部，如果队列为空，则返回 null。 |
| take() | 检索并删除此队列的头部，如果队列为空，则一直等待直到有元素可用。 |
| element() | 检索但不删除此队列的头部，如果队列为空，则抛出异常。 |
| peek() | 检索但不删除此队列的头部，如果队列为空，则返回 null。 |
并发生产消费
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;public class Test {private static int count = 0;private static int pSum = 0;private static int cSum = 0;private static final BlockingQueue queue = new ArrayBlockingQueue<Integer>(10);static class Producer implements Runnable {@Overridepublic void run() {try {for (int i = 0; i < 12; i++) {Thread.sleep(200L);queue.put(1);synchronized (Test.class) {count++;pSum++;System.out.println(Thread.currentThread().getName() + "生产者，目前有" + count + ",共生产" + pSum);}}} catch (Exception e) {e.printStackTrace();}}}static class Consumer implements Runnable {@Overridepublic void run() {try {for (int i = 0; i < 12; i++) {Thread.sleep(200L);queue.take();synchronized (Test.class) {count--;cSum++;System.out.println(Thread.currentThread().getName() + "消费者，目前有" + count + ",共消费" + cSum);}}} catch (Exception e) {e.printStackTrace();}}}public static void main(String[] args) throws Exception{new Thread(new Producer()).start();new Thread(new Producer()).start();new Thread(new Producer()).start();Thread.sleep(2000L);new Thread(new Consumer()).start();new Thread(new Consumer()).start();new Thread(new Consumer()).start();}
}
相关文章：
java并发之BlockingQueue
种类 类名特性ArrayBlockingQueue由数组结构组成的有界阻塞队列LinkedBlockingQueue由链表结构组成的有界的阻塞队列（有界，默认大小 Integer.MAX_VALUE，相当于无界）PriorityBlockingQueue支持优先级排序的无界阻塞队列DelayQueue…...
Python AI 教程之五： 强化学习
强化学习 强化学习：概述 强化学习 (RL) 是机器学习的一个分支，专注于在特定情况下做出决策以最大化累积奖励。与依赖具有预定义答案的训练数据集的监督学习不同，强化学习涉及通过经验进行学习。在强化学习中，代理通过执行操作并通过奖励或惩罚获得反馈来学习在不确定、可…...
uniapp——App下载文件，打开文档（一）
uniapp如何下载文件、打开文件 文章目录 uniapp如何下载文件、打开文件下载文件下载文件成功返回数据格式 打开文档处理 iOS 打开文件可能失败问题 相关API： uni.downloadFileuni.openDocument 注意： 只支持 GET 请求，需要 POST的ÿ…...
【信息系统项目管理师】高分论文：论信息系统项目的沟通管理（监控更新改造项目）
更多内容请见： 备考信息系统项目管理师-专栏介绍和目录 文章目录 论文1、制定沟通管理计划2、管理沟通3、监督沟通论文 2017年8月，我作为项目经理参加了某省委党校校园监控更新改造项目的建设，该项目投资共500万元人民币，建设工期为3个月，通过该项目的建设，实现了安全防…...
鸿蒙应用开发（1）
可能以为通过 鸿蒙应用开发启航计划（点我去看上一节） 的内容，就足够了，其实还没有。 可是我还是要告诉你，你还需要学习新的语言 -- ArkTS。 ，ArkTS是HUAWEI开发的程序语言。你需要学习这门语言。这会花费你…...
基于JavaWeb的汽车维修保养智能预约系统
作者简介：Java领域优质创作者、CSDN博客专家 、CSDN内容合伙人、掘金特邀作者、阿里云博客专家、51CTO特邀作者、多年架构师设计经验、多年校企合作经验，被多个学校常年聘为校外企业导师，指导学生毕业设计并参与学生毕业答辩指导，…...
CAN总线波形中最后一位电平偏高或ACK电平偏高问题分析
参考：https://zhuanlan.zhihu.com/p/689336144 有时候看到CAN总线H和L的差值波形的最后一位电平会变高很多，这是什么原因呢？ 实际上这是正常的现象，最后一位是ACK位。问题描述为：CAN总线ACK电平偏高。 下面分析下原因…...
高等数学学习笔记 ☞ 无穷小与无穷大
1. 无穷小 1. 定义：若函数当或时的极限为零，那么称函数是当或时的无穷小。 备注： ①：无穷小描述的是自变量的变化过程中，函数值的变化趋势，绝不能认为无穷小是一个很小很小的数。 ②：说无穷小时…...
Docker Compose编排
什么是 Docker Compose? Docker Compose 是 Docker 官方推出的开源项目，用于快速编排和管理多个 Docker 容器的应用程序。它允许用户通过一个 YAML 格式的配置文件 docker-compose.yml 来定义和运行多个相关联的应用容器，从而实现对容器的统一管理和编…...
Node.js 处理 GeoPackage 数据的开源库：@ngageoint/geopackage介绍
使用 Node.js 处理 GeoPackage 数据的开源库：@ngageoint/geopackage 随着地理信息系统（GIS）和空间数据的广泛应用，OGC 的 GeoPackage 格式因其轻量、跨平台和高性能的特点，成为处理地理空间数据的重要工具。而对于 Node.js 开发者来说，@ngageoint/geopackage 是一个功能…...
21.＜基于Spring图书管理系统②（图书列表+删除图书+更改图书）（非强制登录版本完结）＞
PS： 开闭原则 定义和背景 开闭原则（Open-Closed Principle, OCP），也称为开放封闭原则，是面向对象设计中的一个基本原则。该原则强调软件中的模块、类或函数应该对扩展开放，对修改封闭。这意味着一个软件实体…...
MySQL日志体系的深度解析：功能与差异
优质博文：IT-BLOG-CN 一、binlog binlog记录数据库表结构和表数据变更，比如update/delete/insert/truncate/create，它不会记录select。存储着每条变更的SQL语句和XID事务Id等等。binlog日志文件如下： [root192.168.10.11]# mysq…...
电商项目-数据同步解决方案（四）商品下架同步更新ES索引库数据
商品下架索引库删除数据 一、 需求分析和业务逻辑 商品下架后将商品从索引库中移除。 主要应用技术有： 消息队列-RabbitMQ ，分布式搜索引擎-ElasticSearch，Eureka，Canal，Feign远程调用 （1）在…...
Kafka
目录 一、什么是Kafka 核心组件 特性 使用场景 安装与配置 二、Kafka的使用 安装 ZooKeeper 和 Kafka 安装 ZooKeeper 安装 Kafka 配置 ZooKeeper 和 Kafka 配置 ZooKeeper 配置 Kafka 启动 ZooKeeper 和 Kafka 创建 Topic 编写生产者代码 编写消费者代码 运行…...
SAP SD学习笔记22 - VF04，VF06，VF24 等一括请求处理
上一篇学习了请求传票（发票）的拷贝管理。 SAP SD学习笔记21 - 请求传票的数据流（拷贝管理）-CSDN博客 本章继续学习 SAP SD的内容。 目录 1，VF04 - 一括请求处理（开票到期清单） 2，…...
JR-RLAA系20路模拟音频多功能编码器
JR-RLAA系20路模拟音频多功能编码器 产品特色 (1)工业级19英寸标准设备，内置双电源 (2)内嵌Web Server，支持远程Web页面登陆后的统一配置操作 (3)支持20路音频输入 (4)支持Dolby Digital(AC-3) ，MPEG-2，AAC-LC/HE-AAC&#x…...
)
数据结构复习 (二叉查找树,高度平衡树AVL)
1.二叉查找树: 为了更好的实现动态的查找(可以插入/删除),并且不超过logn的时间下达成目的 定义: 二叉查找树（亦称二叉搜索树、二叉排序树）是一棵二叉树，其各结点关键词互异，且中根序列按其关键词递增排列。 等价描述: 二叉查找…...
深入浅出梯度下降与反向传播
文章目录 1. 前言2. 基本概念2.1 一元函数的导数2.2 偏导数2.3 方向导数2.4 梯度2.5 均方误差 3. 梯度下降3.1 梯度下降的公式3.2 梯度下降的类型（优化器） 4. 反向传播4.1 反向传播的基本步骤4.2 反向传播的数学推导 5. 实战5.1 手动求导5.2 自动求导5.3…...
)
PLC(01)
一.职业规划 电路----------------->电工------------------>电气-------------------plc---------------------DCS--------------------> 机器人 二.交流电直流电的概念 1.交流电AC alternating current 大小方向随时间发生周期性变化 2.直流电 Direct current…...
)
如何通过本地部署的DIFY辅助学习算法(PS可以辅助帮你学习任何想学习的资料)
如何通过本地部署的DIFY辅助学习算法(PS可以辅助帮你学习任何想学习的资料 一 提升知识库的大小容量1.1 调大知识库的基础配置修改.env文件1.2 通过docker compose 重启加载最新配置1.3 重新上传知识库 二 搭建算法知识库的学习助手2.1 text embedding 模型对比2.1.1 如何选择合…...
深入探讨服务器虚拟化：架构、技术与应用
1. 引言 在现代IT基础设施中，服务器虚拟化已成为一种不可或缺的技术。它不仅提高了资源利用率，还增强了系统的灵活性和可管理性。随着企业对高效、灵活和可扩展IT环境的需求不断增加，服务器虚拟化技术的应用愈发广泛。本文将深入探讨服务器虚…...
C++笔记之尾后迭代器
C笔记之尾后迭代器 code review! 参考笔记 1.C笔记之尾后迭代器 2.C笔记之迭代器失效问题处理 在C中，尾后迭代器（通常称为 past-the-end iterator）是指指向容器中最后一个元素之后的位置的迭代器。它并不指向任何有效的元素，而是…...
2024年总结【第五年了】
2024年总结 北国绕院扫雪，南方围炉烹茶，且饮一杯无? 执笔温暖不曾起舞日子里的点点滴滴，誊写一段回忆，还以光阴一段副本。 那么你要听一支新故事吗？第五年总结的片碎。 衣单天寒，走趟流星孤骑…...
EasyExcel（环境搭建以及常用写入操作）
文章目录 EasyExcel环境搭建1.创建模块 easyexcel-demo2.引入依赖3.启动类创建 EasyExcel写1.最简单的写入1.模板2.方法3.结果 Write01.xlsx 2.指定字段不写入Excel1.模板2.方法3.结果 Write02.xlsx 3.指定字段写入excel1.模板2.方法3.结果 Write03.xlsx 4.按照index顺序写入ex…...
JVM类加载器
什么是类加载器 类加载器（ClassLoader）是Java虚拟机提供给应用程序去实现获取类和接口字节码数据的技术。 类加载器只参与加载过程中的字节码获取并加载到内存这一部分 类加载器的分类 类加载器分为两类，一类是Java代码中实现的࿰…...
druid连接池参数配置
最近发现生产环境经常有数据库连接超时的问题，排查发现是druid连接池参数设置不合理导致 总结问题如下： 为了防止僵尸连接，k8s ipvs做了连接超时限制，如果TCP连接闲置超过900s(15分钟)，客户端再尝试通过这个连接去发起…...
【机器学习】Kaggle实战信用卡反欺诈预测（场景解析、数据预处理、特征工程、模型训练、模型评估与优化）
构建信用卡反欺诈预测模型 建模思路 本项目需解决的问题 本项目通过利用信用卡的历史交易数据，进行机器学习，构建信用卡反欺诈预测模型，提前发现客户信用卡被盗刷的事件。 项目背景 数据集包含由欧洲持卡人于2013年9月使用信用卡进行交的…...
Linux（Ubuntu）下ESP-IDF下载与安装完整流程（2）
接前一篇文章：Linux（Ubuntu）下ESP-IDF下载与安装完整流程（1） 本文主要看参考官网说明，如下： 快速入门 - ESP32-S3 - — ESP-IDF 编程指南 latest 文档 Linux 和 macOS 平台工具链的标准设置 - ESP32-S3 - — ESP-IDF 编程指南 latest 文档 一、安装准备 1. Linux用...
SpringBoot3 快速启动框架
文章目录 1 SpringBoot3 介绍 1.1 SpringBoot3 简介1.2 快速入门1.3 入门总结 2 SpringBoot3 配置文件 2.1 统一配置管理概述2.2 属性配置文件使用2.3 YAML配置文件使用2.4 批量配置文件注入2.5 多环境配置和使用 3 SpringBoot 整合 springMVC 3.1 实现过程3.2 web相关配置3.3…...
Enum枚举类，静态常量类，静态类的区别
Enum枚举类，静态常量类，静态类的区别 Enum枚举类静态常量类静态类Enum枚举类，静态常量类，静态类的区别 Enum枚举类 Enum枚举类的结构组成和用法使用可以查阅 Enum枚举类与静态变量和静态数组的区别 静态常量类 public class St…...
解锁专利世界的钥匙 ——famiwei 网
在知识经济的时代,专利作为创新成果的重要体现,无论是对于企业、科研人员乃至整个社会的发展都具有举足轻重的意义。而在众多的专利网站中,famiwei 网为用户提供了一个全面、精准且高效的专利信息交流与服务的舞台。 一、卓越功能,开启专利探索之门 famiwei 网拥有一套强大的专…...
金融租赁系统的创新与发展推动行业效率提升
金融租赁系统的技术升级与创新 在当今快速发展的金融市场中，金融租赁系统的技术升级与创新充满了无限可能。想象一下，传统的租赁方式就像一位沉闷的老师，而新兴技术就如同一位活泼的学生，不断追求新鲜事物。通过自动化、人工智能…...
SQL-Server链接服务器访问Oracle数据
SQL Server 链接服务器访问 Oracle 离线安装 .NET Framework 3.5 方法一：使用 NetFx3.cab 文件 下载 NetFx3.cab 文件，并将其放置在 Windows 10 系统盘的 C:Windows 文件夹中。 以管理员身份运行命令提示符，输入以下命令并回车： …...
Sonic：开源Go语言开发的高性能博客平台
Sonic：一个用Go语言开发的高性能博客平台 简介 Sonic，一个以其速度如声速般快速而命名的博客平台，是一个用Go语言开发的高性能博客系统。正如其名字所暗示的，Sonic旨在提供一个简单而强大的博客解决方案。这个项目受到了Halo项目…...
【react】常见的性能优化 1
目录 常见的 React 性能优化手段 1. 使用 useMemo 和 useCallback 缓存数据和函数 2. 使用 React.memo 缓存组件 3. 组件懒加载 4. 合理使用 key 5. 在组件销毁时清除定时器/事件 6. 使用 Suspense 和 Lazy 拆分组件 7. 使用 Fragment 避免额外标记 8. 避免使用内联函…...
SpringCloud源码-openFeign
LoadBalancer默认只有nacos服务发现器 openFeign与springcloud loadbalancer的结合点...
QLabel添加点击处理
在QLabel中添加点击事件有三种方式，分别是 使用LinkActivated信号连接槽函数（有缺限）注册事件分发器eventFilter创建类重写鼠标事件 1. 使用LinkActivated信号 QLabel类中有LinkActivated信号，是当标签中的链接被点击的时候触发…...
Markdown表格的使用
Markdown表格的使用 前言语法详解定义表格设定表格列内容的对齐方式 使用场景及实例小结其他文章快来试试吧 Markdown表格的使用👈点击这里也可查看 前言 表格通常作为一种布局的形式，用于结构化的数据展示。 Markdown表格包含三个部分：表头…...
时间序列预测算法介绍
时间序列预测是根据时间序列数据的历史变化规律，对未来数据进行预测的方法。在给定的代码中，使用的是自回归（AR）模型中的AR(4)模型来预测光伏功率。以下将详细解释这种算法： 1. 自回归模型（AR模型…...
加密流量TLS1.2 和TLS1.3的握手区别
加密流量TLS1.2 和TLS1.3的握手区别 TLS1.2 握手均是明文 1）Client Hello 2）Server Hello 3）Certificate TLS1.3 握手中Client Hello是明文，而Server Hello中Extensions以及后面的握手信息不可见 1）Client Hello…...
MySQL数据库——主从复制
本文详细介绍 MySQL的主从复制，从原理到配置再到同步过程。 文章目录 简介核心组件主从复制的原理作用主从复制的线程模型主从复制的模式形式复制的方式设计复制机制主从复制的配置步骤优化和改进总结 简介 MySQL 主从复制（Replication）是一…...
详细说明嵌入式linux中bootcmd与bootargs差异
bootcmd 和 bootargs 是在嵌入式系统开发，特别是基于U-Boot（一个广泛应用的开源引导加载程序）环境中常见的两个重要参数，它们的区别如下： 功能用途 bootcmd： 定义：bootcmd 是U-Boot中的一个环…...
【UE5】UnrealEngine源码构建2：windows构建unreal engine 5.3.2
参考大神知乎的文章：UE5 小白也能看懂的源码编译指南 据说会耗费400G的空间。 代码本身并不大，可能是依赖特别多，毕竟看起来UE啥都能干，核心还是c++的， 【UE5】UnrealEngine源码构建1：tag为5.3.2源码clone 本着好奇+ 学习的态度，想着也许有机会能更为深入的熟悉UE的机制…...
【YOLO算法改进】ALSS-YOLO：无人机热红外图像｜野生动物小目标检测
目录 论文信息 论文创新点 1.自适应轻量通道分割和洗牌（ALSS）模块 2.轻量坐标注意力（LCA）模块 3.单通道聚焦模块 4.FineSIOU损失函数 摘要 架构设计 轻量高效网络架构 - ALSS模块 LCA模块 单通道聚焦模块 损失函数优…...
时间序列预测算法---LSTM
文章目录 一、前言1.1、深度学习时间序列一般是几维数据？每个维度的名字是什么？通常代表什么含义？1.2、为什么机器学习/深度学习算法无法处理时间序列数据?1.3、RNN(循环神经网络)处理时间序列数据的思路？1.4、RNN存在哪些问题?…...
【QT】：QT图形化界面概述
Qt背景介绍 1.1 什么是Qt Qt 是⼀个跨平台的C图形⽤⼾界⾯应⽤程序框架。它为应⽤程序开发者提供了建⽴艺术级图形 界⾯所需的所有功能。它是完全⾯向对象的，很容易扩展。Qt为开发者提供了⼀种基于组件的开发模 式，开发者可以通过简单的拖拽和组合来实现…...
[论文笔记]Representation Learning with Contrastive Predictive Coding
引言 今天带来论文 Representation Learning with Contrastive Predictive Coding的笔记。 提出了一种通用的无监督学习方法从高维数据中提取有用表示，称为对比预测编码(Contrastive Predictive Coding,CPC)。使用了一种概率对比损失， 通过使用负采样使…...
Redis相关
Redis相关 什么是redis?redis可以干什么? Redis是一个c语言编写的nosql数据库(不仅仅是sql,泛指非关系型数据库,一般把非关系型数据库称为nosql数据库),数据在内存中以键值对的形式存储,读写速度快,提供数据持久化方式. 常常被广泛应用到做缓存 Redis使用场景 1.缓存 2…...
【优选算法】Binary-Blade：二分查找的算法刃（上）
文章目录 1.概念解析2.二分查找的简单模版3.二分查找的进阶模版4.x的平方根5.搜索插入位置希望读者们多多三连支持小编会继续更新你们的鼓励就是我前进的动力！ 本篇是优选算法之二分查找算法，该算法是一种高效的在有序数组中查找特定元素的搜索算法 1.概…...
Docker--Docker Network（网络）
Docker Network（网络）是Docker容器之间和容器与外部网络之间的通信和连接的一种机制。以下是对Docker Network的详细解释： 一、Docker网络的重要性 Docker容器网络是为应用程序所创造的虚拟环境的一部分，它能让应用从宿主机操作…...