个人建网站wordpress/优化落实新十条措施
JUC并发编程_Lock锁
- 1、Lock锁介绍
- 2、主要方法
- 3、与 synchronized 的区别
- 4、Condition 使用示例
1、Lock锁介绍
Java中的 Lock
锁是 java.util.concurrent.locks
包下的一个接口,它提供了比 synchronized
关键字更灵活的锁定机制。
2、主要方法
lock()
:获取锁。如果锁不可用,则当前线程将被禁用,直到锁变为可用。tryLock()
:尝试获取锁,如果锁可用,则获取锁并立即返回true;如果锁不可用,则立即返回false,并且当前线程不会被禁用。tryLock(long time, TimeUnit unit)
:尝试获取锁,如果锁在给定的等待时间内可用,并且当前线程未被中断,则获取锁。lockInterruptibly()
:用于以可中断的方式获取锁。这个方法与 lock() 方法的主要区别在于,当线程尝试获取锁而锁已被其他线程持有时,lock() 方法会使线程在锁上无限期地等待,直到锁变为可用;而 lockInterruptibly() 方法允许等待锁的线程在等待过程中响应中断unlock()
:释放锁newCondition()
:返回绑定到此 Lock 实例的新 Condition 实例。Condition 提供了与Object监视器方法(如wait、notify和notifyAll)类似的功能,但与Lock实例相关联。
3、与 synchronized 的区别
灵活性
:Lock 锁提供了比 synchronized 更灵活的锁定操作。例如,tryLock
方法允许在不能立即获取锁时不会使线程进入阻塞状态,而是返回一个布尔值。可中断性
:Lock 锁支持获取锁时的中断响应,而 synchronized 不支持。这意味着如果某个线程在等待锁的过程中被中断,它可以立即响应中断,而不是无限期地等待超时尝试
:Lock 锁允许尝试获取锁时设置超时时间,如果在这个时间内锁没有被获取到,则线程可以放弃等待,去做其他事情条件变量
:Lock 锁提供了 Condition 接口,支持多个条件变量,而 synchronized 关键字则只有一个条件变量(即对象监视器)锁的获取和释放
:synchronized 锁的获得和释放都是自动的,Lock 锁需要手动获取和释放。锁的公平性
:synchronized 锁是非公平锁,Lock 锁默认是非公平锁的,但可以通过构造函数传参改变为公平锁。精准唤醒
:synchronized 的唤醒机制是基于 wait/notify 或 notifyAll 方法的,其中 notify 方法只能随机唤醒等待队列中的一个线程,无法做到精准唤醒。Lock 锁可以通过操作不同 Condition 实例的 signal() 方法实现精准唤醒。
4、Condition 使用示例
创建一个简单的生产者-消费者场景,其中使用 ReentrantLock(Lock接口的一个实现)和 Condition 来控制对共享资源的访问
import java.util.LinkedList;
import java.util.Queue;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock; public class ProducerConsumerExample { private final Queue<Integer> queue = new LinkedList<>(); private final int capacity = 10; private final Lock lock = new ReentrantLock(); private final Condition notFull = lock.newCondition(); private final Condition notEmpty = lock.newCondition(); public void produce(int value) throws InterruptedException { lock.lock(); try { while (queue.size() == capacity) { // 当队列满时,生产者等待 notFull.await(); } queue.add(value); System.out.println("Produced: " + value); // 通知消费者队列中有新元素 notEmpty.signal(); } finally { lock.unlock(); } } public void consume() throws InterruptedException { lock.lock(); try { while (queue.isEmpty()) { // 当队列空时,消费者等待 notEmpty.await(); } int value = queue.poll(); System.out.println("Consumed: " + value); // 通知生产者队列中有空间 notFull.signal(); } finally { lock.unlock(); } } public static void main(String[] args) { ProducerConsumerExample example = new ProducerConsumerExample(); // 创建生产者和消费者线程 Thread producer = new Thread(() -> { for (int i = 0; i < 20; i++) { try { example.produce(i); Thread.sleep(100); // 模拟耗时操作 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }); Thread consumer = new Thread(() -> { for (int i = 0; i < 20; i++) { try { example.consume(); Thread.sleep(150); // 模拟耗时操作 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }); // 启动线程 producer.start(); consumer.start(); }
}
- await() 方法
await() 方法是 Condition 接口中的一个方法,它会使当前线程进入等待状态(即阻塞),直到其他线程调用该Condition 的 signal() 或 signalAll() 方法,或者当前线程被中断,或者等待过程中发生了 InterruptedException 异常。
在调用 await() 方法之前,当前线程必须已经获得了与 Condition 相关联的锁。调用 await() 方法后,当前线程会释放这个锁,并进入等待状态。当线程从 await() 方法返回时,它必须重新获取这个锁才能继续执行。
在 ProducerConsumerExample 的 produce 方法中,当队列满时,生产者线程会调用 notFull.await() 等待,直到有消费者线程消费了队列中的元素并调用了 notFull.signal() 或 notFull.signalAll() 方法。
在 consume 方法中,当队列空时,消费者线程会调用 notEmpty.await() 等待,直到有生产者线程生产了新的元素并调用了 notEmpty.signal() 或 notEmpty.signalAll() 方法。
- signal() 方法
signal() 方法是 Condition 接口中的一个方法,它用于唤醒等待在该 Condition 上的单个线程(如果有的话)。在调用 signal() 方法之前,当前线程必须已经获得了与 Condition 相关联的锁。
在 ProducerConsumerExample 的 produce 方法中,当生产者线程成功地将一个元素添加到队列中后,它会调用 notEmpty.signal() 来唤醒可能正在等待的消费者线程(如果有的话),以便消费者线程可以消费这个新元素。
在 consume 方法中,当消费者线程成功地从队列中取出一个元素后,它会调用 notFull.signal() 来唤醒可能正在等待的生产者线程(如果有的话),以便生产者线程可以继续生产新的元素。
需要注意的是,signal() 方法只会唤醒等待队列中的一个线程,而 signalAll() 方法会唤醒等待队列中的所有线程。在这个例子中,我们使用了 signal() 方法,因为生产者-消费者问题通常只需要唤醒一个等待的线程(生产者唤醒消费者,或消费者唤醒生产者)。然而,在某些情况下,使用 signalAll() 可能更合适,特别是当你不确定应该唤醒哪个线程时。但是,使用 signalAll() 可能会导致不必要的线程唤醒和竞争,从而影响性能。
相关文章:

JUC并发编程_Lock锁
JUC并发编程_Lock锁 1、Lock锁介绍2、主要方法3、与 synchronized 的区别4、Condition 使用示例 1、Lock锁介绍 Java中的 Lock 锁是 java.util.concurrent.locks 包下的一个接口,它提供了比 synchronized 关键字更灵活的锁定机制。 2、主要方法 lock():…...

Unity中的功能解释(数学位置相关和事件)
向量计算 Vector3.Slerp(起点坐标,终点坐标,t),可是从起点坐标以一个圆形轨迹到终点坐标,有那么多条轨迹,那怎么办 Vector3.Slerp 进行的是沿球面插值,因此并不是沿着严格的“圆形…...

ElementPlus---Timeline 时间线组件使用示例
介绍 使用ElementPlus时间线组件在后台首页实现通知公告列表展示,使用Vue3开发。 实现代码 Vue3代码 <el-timeline><el-timeline-itemstyle"max-width: 600px"v-for"(activity, index) in activities":key"index":times…...

推荐4款2024年大家都在用的高质量翻译器。
翻译器在我们的生活中有着很重要的作用,不管是我们在学习还是工作,生活娱乐,出国旅游等场合都会派上用场,它是我们解决沟通的障碍,提高阅读效率的好帮手。我自己使用的翻译器有很多,可以给大家列举几款特别…...

Mybatis 返回 Map 对象
一、场景介绍 假设有如下一张学生表: CREATE TABLE student (id int NOT NULL AUTO_INCREMENT COMMENT 主键,name varchar(100) NOT NULL COMMENT 姓名,gender varchar(10) NOT NULL COMMENT 性别,grade int NOT NULL COMMENT 年级,PRIMARY KEY (id) ) ENGINEInnoD…...

Vue3(三)路由基本使用、工作模式(history,hash)、query传参和param传参、props配置、编程式路由导航
文章目录 一、路由的基本使用二、路由器的工作模式三、RouterLink中to的两种写法四、嵌套路由五、路由传参1. query传参2. params传参 六、路由的propos配置七、编程式路由导航 一、路由的基本使用 安装:npm i vue-router 在src/pages文件下,创建三个路…...

TypeScript概念讲解
简单来说,TypeScript 是 JavaScript 的一个超集,支持 ECMAScript 6 标准; TypeScript 由微软开发的自由和开源的编程语言; TypeScript 设计目标是开发大型应用,它可以编译成纯 JavaScript,编译出来的 Jav…...

C++ | Leetcode C++题解之第437题路径总和III
题目: 题解: class Solution { public:unordered_map<long long, int> prefix;int dfs(TreeNode *root, long long curr, int targetSum) {if (!root) {return 0;}int ret 0;curr root->val;if (prefix.count(curr - targetSum)) {ret pref…...

回复《对话损友 2》
回复《对话损友 2》 承蒙贵人挂念,亦感激贵人给予这般交流的契机(对话损友 2 -- 回复-CSDN博客)。我自身也一直期望能留存些岁月的痕迹,然而却常困惑于不知哪些事物值得铭记,哪些又应被永远忘却。 随着时光流转&#x…...

MySQL - 运维篇
一、日志 1. 错误日志 2. 二进制日志 3. 查询日志 记录了所有的增删改查语句以及DDL语句 4. 慢查询日志 二、主从复制 1. 概述 2. 原理 3. 搭建 三、分库分表 1. 介绍 2. Mycat概述 3. Mycat入门 4. Mycat配置 5. Mycat分片 6. Mycat管理及监控 四、读写分离 1. 介绍 2. 一…...

WebGIS开发及市面上各种二三维GIS开发框架对比分析
GIS前端开发是现代WebGIS应用开发中非常重要的一环,通过前端开发框架,可以实现地图展示、交互、分析等功能。本文将介绍当前市面上常用的GIS前端开发框架,并进行对比分析。 Leaflet Leaflet是一款轻量级的开源地图库,它提供了丰…...

[论文精读]TorWard: Discovery, Blocking, and Traceback of Malicious Traffic Over Tor
期刊名称:IEEE Transactions on Information Forensics and Security 发布链接:TorWard: Discovery, Blocking, and Traceback of Malicious Traffic Over Tor | IEEE Journals & Magazine | IEEE Xplore 中文译名:TorWard:…...

pytest - 多线程提速
import timedef test1_test1():time.sleep(1)assert 1 1, "11"def test1_test2():time.sleep(1)assert 1 1, "11" 上面2个函数,执行情况: 正常执行时,花费 2.08s2个进程执行时,花费 1.18s2个线程执行时&a…...

python中logging的用法
logging.error 是 Python logging 模块中的一个方法,专门用于记录错误级别(ERROR)的日志信息。logging 模块是 Python 提供的标准日志工具,用于生成各种级别的日志消息,并支持日志的格式化和存储。 logging.error 的基…...

【YOLO目标检测车牌数据集】共10000张、已标注txt格式、有训练好的yolov5的模型
目录 说明图片示例 说明 数据集格式:YOLO格式 图片数量:10000(2000张绿牌、8000张蓝牌) 标注数量(txt文件个数):10000 标注类别数:1 标注类别名称:licence 数据集下载:车牌数据…...

gdb xterm 调试 openmpi 程序
1,编写编译一个openmpi程序 迭代计算 PI 的源程序: pi_reduce.c #include <stdio.h>#include <math.h> #include <mpi.h>double f(double); double f(double x) {return (4.0/(1.0x*x)); }int main(int argc, char* argv[]) {int d…...

【STM32】江科大STM32笔记汇总(已完结)
STM32江科大笔记汇总 STM32学习笔记课程简介(01)STM32简介(02)软件安装(03)新建工程(04)GPIO输出(05)LED闪烁& LED流水灯& 蜂鸣器(06)GPIO输入(07)按键控制LED 光敏传感器控制蜂鸣器(08)OLED调试工具(09)OLED显示屏(10)EXTI外部中断(11)对射式红外传感器计次 旋转编码器…...

Java基础扫盲(二)
想看Java基础扫盲(一)的可以观看我的上篇文章Java基础扫盲 目录 String为什么设计为不可变的 String有长度限制吗 为什么JDK9将String的char[]改为byte[] 泛型中K,T,V,E,Object,?等都代表什么含义 怎么修改一个类中使用了private修饰的String类型…...

兼容React的刮刮乐完整代码实现
需要兼容React的刮刮乐完整代码实现 在现代Web开发中,React作为一种流行的前端框架,为开发者提供了构建动态界面的强大工具。刮刮乐效果作为一种趣味性的用户交互,能够显著提升用户体验和参与度。本文将详细介绍如何在React项目中实现一个兼…...

PHP程序如何实现限制一台电脑登录?
PHP程序如何实现限制一台电脑登录? 可以使用以下几种方法: 1. IP地址限制:在PHP中,可以通过获取客户端的IP地址,然后与允许登录的IP地址列表进行比对。如果客户端的IP地址不在列表中,就禁止登录。 “php $…...

nodejs fs 模块的简介与相关案例
fs 文件系统模块 什么是 fs 文件系统模块? fs 模块是 Node.js 官方提供的、用来操作文件的模块。它提供了一系列的方法和属性,用来满足用户对文件的操作要求。* 例如: fs.readFile() 方法用来读取文件内容。fs.writeFile() 方法用来写入文…...

计算机毕业设计 基于Flask+Vue的博客系统 Python毕业设计 前后端分离 附源码 讲解 文档
🍊作者:计算机编程-吉哥 🍊简介:专业从事JavaWeb程序开发,微信小程序开发,定制化项目、 源码、代码讲解、文档撰写、ppt制作。做自己喜欢的事,生活就是快乐的。 🍊心愿:点…...

基于SSH的酒店管理系统的设计与实现 (含源码+sql+视频导入教程)
👉文末查看项目功能视频演示获取源码sql脚本视频导入教程视频 1 、功能描述 基于SSH的酒店管理系统拥有两种角色 管理员:房间管理、房型管理、客户管理、预定管理、入住管理(到店入住、预定入住、正在入住)、账单管理、会员管理…...

消息队列10:为RabbitMq添加连接池
环境: win11rabbitmq-3.8.17.net 6.0RabbitMQ.Client 6.8.1vs2022 安装RabbitMq环境参照: window下安装rabbitmqlinux下安装rabbitmq 问题:rabbitmq的c#客户端没有自带连接池,所以需要手动实现。 简易实现如下: usi…...

在使用 Docker 时,用户可能会遇到各种常见的错误和问题
在使用 Docker 时,用户可能会遇到各种常见的错误和问题。以下是一些需要注意的常见错误及其可能的解决方案: 1. 权限问题 在 Linux 系统上运行 Docker 命令时,可能会遇到权限不足的问题。解决这个问题通常有两种方法: 使用 sud…...

MinIO使用客户端进行桶和对象的管理
MinIO使用客户端进行桶和对象的管理 minio安装完成后,除了自带的webui管理界面,还可以使用官方配套的客户端mc进行管理。除此之外,还可以使用第三方客户端s3browser也可以完成对象和桶的生命周期管理。 1. 官方客户端mc MinIO客户端 mc 命…...

数据库管理-第244期 一次无法switchover的故障处理(20240928)
数据库管理244期 2024-09-28 数据库管理-第244期 一次无法switchover的故障处理(20240928)1 问题展现2 问题排查与处理2.1 问题12.2 问题2 3 问题分析4 总结 数据库管理-第244期 一次无法switchover的故障处理(20240928) 作者&…...

太绝了死磕这本大模型神书!
今天给大家推荐一本大模型神书,就是这本:《大语言模型:基础与前沿》 书籍介绍: 本书深入阐述了大语言模型的基本概念和算法、研究前沿以及应用,涵盖大语言模型的广泛主题,从基础到前沿,从方法…...

Kevin‘s notes about Qt---Episode 6 不同类中创建同一对象
问题描述 使用场景 现在在我的Qt界面中需要同时使用采集卡的AI(Analog Input)和AO(Analog Output)功能,均已分别调通,但是像之前一样通过创建两个类,然后分别在两个线程中进行操作的方式并不能实现。 原本写法 头文件 art_ao.h 核心代码如下: #ifndef ART_AO_H #defi…...

YOLOv9改进策略【Conv和Transformer】| AssemFormer 结合卷积与 Transformer 优势,弥补传统方法不足
一、本文介绍 本文记录的是利用AssemFormer优化YOLOv9的目标检测网络模型。传统卷积和池化操作会导致信息丢失和压缩缺陷,且传统的注意力机制通常产生固定维度的注意力图,忽略了背景中的丰富上下文信息。本文的利用AssemFormer改进YOLOv9,以在特征传递和融合过程中增加多尺…...