简单了解下Java中锁的概念和原理

你好,这里是codetrend专栏“高并发编程基础”。

Java提供了很多种锁的接口和实现,通过对各种锁的使用发现理解锁的概念是很重要的。

Java的锁通过java代码实现,go语言的锁通过go实现,python语言的锁通过python实现。它们都实现的什么呢?这部分就是锁的定义和设计模式、算法、原理等一些理论上的东西。

下文基于此说明Java常见的锁分类和原理。

乐观锁&悲观锁

乐观锁和悲观锁是在并发编程中保证数据一致性的两种常见的锁机制。

乐观锁:乐观锁假设在大多数情况下,不会出现并发冲突,因此在读取数据时并不加锁,只有在提交更新时才会检查是否有其他并发操作修改了数据。如果检测到了冲突,就放弃当前的操作并返回错误信息。通常采用版本号或时间戳等机制来实现乐观锁。乐观锁机制适用于读操作频繁、写操作较少的场景。

悲观锁:悲观锁则假设并发冲突随时都可能发生,因此在读取数据时就会加锁,直到操作完成后才会释放锁。一般可以使用数据库中的行级锁、表级锁或者使用 synchronized 等语言提供的锁机制来实现悲观锁。悲观锁机制适用于写操作频繁、读操作较少的场景。

选择何种锁机制应根据具体的应用场景进行选择。在读写比例不明显的情况下,可以考虑使用乐观锁机制,这样可以减少锁竞争带来的性能损失。如果读写比例明显,考虑使用悲观锁机制可以更好地确保数据的一致性。

需要注意的是,在实际应用中,乐观锁和悲观锁并不是严格的对立关系,而是可以结合使用的。例如,在高并发场景中,可以使用乐观锁机制来减少对数据库的压力,但在必要的时候也可以使用悲观锁机制来确保数据的一致性。

下面是使用 Java 实现一个简单的乐观锁和悲观锁的示例:

乐观锁示例

import java.util.concurrent.atomic.AtomicInteger;public class OptimisticLock {private AtomicInteger value = new AtomicInteger(0);public void increment() {int oldValue, newValue;while (!value.compareAndSet(oldValue, newValue)){// CAS操作,如果值没有被修改,则更新为新值// 读取当前值oldValue = value.get();// 计算新值newValue = oldValue + 1;} }public int getValue() {return value.get();}
}

悲观锁示例

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;public class PessimisticLock {private int value = 0;private Lock lock = new ReentrantLock();public void increment() {lock.lock(); // 加锁try {value++; // 更新数据} finally {lock.unlock(); // 解锁}}public int getValue() {return value;}
}

公平锁&非公平锁

公平锁:公平锁保证线程获取锁的顺序与其请求锁的顺序相同,即先到先得。当多个线程同时竞争同一个公平锁时,这些线程会按照先后顺序排队等待获取锁。公平锁可以避免饥饿现象,但是由于需要维护一个有序队列,因此性能较低。

非公平锁:非公平锁则不保证线程获取锁的顺序,即先到不一定先得。当一个线程释放锁时,如果有多个线程正在等待获取锁,那么当前持有锁的线程有可能会再次获取到锁,而不是让等待时间最长的线程获取锁。非公平锁具有更高的吞吐量和更低的竞争开销,但是容易导致某些线程长时间等待,出现饥饿现象。

在 Java 中,可以使用 ReentrantLock 类来实现公平锁和非公平锁。默认情况下,ReentrantLock 类使用非公平锁,可以通过构造函数传入 true 来创建公平锁,例如:

// 创建公平锁
Lock fairLock = new ReentrantLock(true);// 创建非公平锁
Lock unfairLock = new ReentrantLock(false);

自旋锁&适应性自旋锁

自旋锁和适应性自旋锁都是基于忙等待的锁机制,它们在获取锁时不会立即阻塞线程,而是反复检查锁的状态,直到获取到锁为止。下面对每种锁做一些说明,并提供Java中的实现示例。

自旋锁:自旋锁适合用于锁持有时间非常短暂的情况,可以避免线程切换带来的开销。自旋锁的基本思想是,当线程发现共享资源已经被其他线程占用时,就进行自旋等待,直到占用共享资源的线程释放锁为止。Java中的ReentrantLock就支持自旋锁,可以通过构造函数的参数来设置自旋次数,例如:

ReentrantLock lock = new ReentrantLock(true); // 使用公平锁
lock.lock(); // 获取锁
// 共享资源的访问操作
lock.unlock(); // 释放锁

适应性自旋锁:适应性自旋锁是一种优化过的自旋锁,它会根据前一次在同一个锁上的自旋时间和锁的拥有者情况来确定自旋次数。如果在同一个锁上,前一次自旋的时间较长,那么下一次就会更倾向于阻塞线程而不是自旋等待。这样可以避免长时间的自旋等待,减少资源的浪费。Java中的StampedLock就是支持适应性自旋锁的一种锁机制,例如:

StampedLock lock = new StampedLock();
long stamp = lock.readLock(); // 获取悲观读锁
// 共享资源的访问操作
lock.unlockRead(stamp); // 释放悲观读锁

无锁 & 偏向锁 & 轻量级锁 & 重量级锁

无锁、偏向锁、轻量级锁和重量级锁都是Java中不同的锁状态,用于实现线程同步的机制。

无锁:无锁是指在多线程环境下,对共享资源的访问没有任何同步控制,所有线程可以同时访问共享资源,不会发生争用。无锁适用于只读操作或者线程冲突非常少的情况。例如:

int value = sharedValue; // 读取共享资源

偏向锁:偏向锁是一种针对加锁操作进行优化的机制,它适用于只有一个线程反复获取锁的情况。当一个线程首次获取锁时,会将锁的标记设置为该线程,下次该线程再次获取锁时无需竞争,直接进入临界区。偏向锁的目标是提高单线程下的性能。例如:

// 线程1首次获取锁
synchronized (lock) {// 临界区代码
}// 线程1再次获取锁
synchronized (lock) {// 临界区代码
}

轻量级锁:轻量级锁是一种基于CAS(Compare and Swap)操作的锁机制,它适用于多个线程交替执行同一段临界区代码的情况。当一个线程获取锁时,会尝试使用CAS操作将对象头部的锁记录替换为指向自己的线程ID,如果成功,则表示获取锁成功;否则,表示有其他线程竞争锁,可能发生锁膨胀。例如:

Lock lock = new ReentrantLock();
lock.lock(); // 获取锁
try {// 临界区代码
} finally {lock.unlock(); // 释放锁
}

重量级锁:重量级锁是一种基于操作系统互斥量(Mutex)的锁机制,它适用于多个线程频繁竞争同一把锁的情况。当一个线程获取锁时,会进入阻塞状态,直到锁被释放,然后唤醒其他线程进行竞争。重量级锁适用于线程冲突比较频繁的情况。例如:

synchronized (obj) {// 临界区代码
}

可重入锁 & 非可重入锁

可重入锁:可重入锁是指允许同一线程多次获取同一把锁,而不会发生死锁或者其他异常情况。当一个线程获取锁后,再次尝试获取锁时会自动成功,并且需要释放相同次数的锁才能真正释放锁。Java中的ReentrantLock和synchronized都支持可重入锁,例如:

// ReentrantLock示例
ReentrantLock lock = new ReentrantLock();
lock.lock(); // 获取锁
try {// 临界区代码lock.lock(); // 再次获取锁try {// 嵌套临界区代码} finally {lock.unlock(); // 释放嵌套锁}
} finally {lock.unlock(); // 释放锁
}

非可重入锁:非可重入锁是指同一线程不能多次获取同一把锁,否则会导致死锁或者其他异常情况。Java中的普通对象锁就是一种非可重入锁,例如:

package engineer.concurrent.battle.glock;public class LockEnterNoRepeat {private static Object lock = new Object();public static void main(String[] args) {synchronized (lock) {// 临界区代码synchronized (lock) { // 再次获取锁会导致死锁// 嵌套临界区代码System.out.println("thread end");}}}
}

需要注意的是,可重入锁虽然提供了更大的灵活性和便利性,但也要注意避免死锁和其他问题的发生。在设计和使用多线程代码时,应该根据具体情况选择合适的锁机制。

独享锁 & 共享锁

独享锁Exclusive Lock是指在某个时间点只允许一个线程持有锁,其他线程不能同时持有该锁。独享锁也被称为排它锁或写锁,用于保护临界资源的独占访问。

共享锁Shared Lock是指在某个时间点允许多个线程同时持有锁,这些线程可以同时访问被保护的资源,但是不能进行写操作。共享锁也被称为读锁,用于实现读多写少的并发模式。

在Java中,ReentrantReadWriteLock是一种同时支持独享锁和共享锁的锁机制。通过使用ReentrantReadWriteLock,可以在不同的线程之间实现对共享资源的读写操作控制。

下面是使用ReentrantReadWriteLock实现独享锁和共享锁的示例代码:

import java.util.concurrent.locks.ReentrantReadWriteLock;public class ReadWriteLockExample {private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();private String data = "Hello, World!";public void readData() {lock.readLock().lock();try {System.out.println("Reading data: " + data);} finally {lock.readLock().unlock();}}public void writeData(String newData) {lock.writeLock().lock();try {System.out.println("Writing data: " + newData);data = newData;} finally {lock.writeLock().unlock();}}public static void main(String[] args) {ReadWriteLockExample example = new ReadWriteLockExample();// 创建多个读线程for (int i = 0; i < 3; i++) {Thread readerThread = new Thread(() -> {example.readData();});readerThread.start();}// 创建一个写线程Thread writerThread = new Thread(() -> {example.writeData("New data");});writerThread.start();}
}

运行该程序会输出以下结果:

Reading data: Hello, World!
Reading data: Hello, World!
Reading data: Hello, World!
Writing data: New data

可以看到,有三个读线程同时获取了共享锁,并读取了数据。而在写线程中,只有该线程获取了独享锁,并成功修改了数据。

通过ReentrantReadWriteLock,我们可以实现对共享资源的读操作并发执行,提高读操作的效率;而写操作会独占锁,保证在写操作时只有一个线程能够访问临界资源,确保数据一致性。

关于作者

来自全栈程序员nine的探索与实践,持续迭代中。

欢迎关注和点赞~

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/37796.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Apache Calcite Linq4j学习

Lin4j简介 Linq4j是Apache Calcite项目中的一个模块&#xff0c;它提供了类似于LINQ&#xff08;Language-Integrated Query&#xff09;的功能&#xff0c;用于在Java中进行数据查询和操作。Linq4j可以将逻辑查询转换为物理查询&#xff0c;支持对集合进行筛选、映射、分组等…

python自动例化verilog

python自动例化verilog 使用方法&#xff1a;在gvim页面&#xff0c;使用命令自动例化 :r !AUTO_inst xxx.v #python import re import sysmdl_re r"\s*module\s*(?P<mname>\w) *" port_re r"\s*(?P<dir>input|output)\s(?P<typ>wire|re…

API-节点操作

学习目标&#xff1a; 掌握节点操作 学习内容&#xff1a; DOM节点查找节点增加节点删除节点 DOM节点&#xff1a; DOM树里每一个内容都称之为节点。 节点类型 元素节点所有的标签比如body、div&#xff1b;html是根节点属性节点所有的属性&#xff0c;比如href文本节点所有…

FastAPI-Cookie

fastapi-learning-notes/codes/ch01/main.py at master Relph1119/fastapi-learning-notes GitHub 1、Cookie的作用 Cookie可以充当用户认证的令牌&#xff0c;使得用户在首次登录后无需每次手动输入用户名和密码&#xff0c;即可访问受限资源&#xff0c;直到Cookie过期或…

《PyTorch计算机视觉实战》:一、二章

目录 第一章&#xff1a;人工神经网络基础 比较人工智能和传统机器学习 人工神经网络&#xff08;Artificial Neural Network&#xff0c;ANN&#xff09; 是一种受人类大脑运作方式启发而构建的监督学习算法。神经网络与人类大脑中神经元连接和激活的方式比较类似&#xff0…

mysql查看用户的过期时间

1. mysql查看用户的过期时间的方法 在MySQL中&#xff0c;用户的过期时间&#xff08;也称为账户过期日期&#xff09;是一个可选项&#xff0c;用于确定某个MySQL用户账户何时到期。但是&#xff0c;值得注意的是&#xff0c;并非所有的MySQL安装或版本都支持直接设置用户账户…

GoLang语言

基础 安装Go扩展 go build 在项目目录下执行go build go run 像执行脚本文件一样执行Go代码 go install go install分为两步&#xff1a; 1、 先编译得到一个可执行文件 2、将可执行文件拷贝到GOPATH/bin Go 命令 go build :编译Go程序 go build -o "xx.exe"…

CSS元素之间的空白问题:原因与解决方案

在网页设计中&#xff0c;CSS元素之间的空白是一个常见但往往不易察觉的问题。空白不仅影响布局的准确性&#xff0c;还可能破坏设计的整体美感。本文将探讨元素之间空白的产生原因&#xff0c;并提供有效的解决方案。 空白产生的根源 空白问题主要发生在行内元素和行内块元素…

4.x86游戏实战-人物状态标志位

免责声明&#xff1a;内容仅供学习参考&#xff0c;请合法利用知识&#xff0c;禁止进行违法犯罪活动&#xff01; 本次游戏没法给 内容参考于&#xff1a;微尘网络安全 上一个内容&#xff1a;3.x86游戏实战-寄存器 人物状态标志位&#xff1a; 什么叫人物状态标志位&…

力扣刷题--3168. 候诊室中的最少椅子数【简单】

题目描述 给你一个字符串 s&#xff0c;模拟每秒钟的事件 i&#xff1a; 如果 s[i] ‘E’&#xff0c;表示有一位顾客进入候诊室并占用一把椅子。 如果 s[i] ‘L’&#xff0c;表示有一位顾客离开候诊室&#xff0c;从而释放一把椅子。 返回保证每位进入候诊室的顾客都能有…

Leetcode[反转链表]

LCR 024. 反转链表 给定单链表的头节点 head &#xff0c;请反转链表&#xff0c;并返回反转后的链表的头节点。 示例 1&#xff1a; 输入&#xff1a;head [1,2,3,4,5] 输出&#xff1a;[5,4,3,2,1]示例 2&#xff1a; 输入&#xff1a;head [1,2] 输出&#xff1a;[2,1]示…

Go使用Gin框架开发的Web程序部署在Linux时,无法绑定监听Ipv4端口

最近有写一部分go语言开发的程序&#xff0c;在部署程序时发现&#xff0c;程序在启动后并没有绑定ipv4的端口&#xff0c;而是直接监听绑定ipv6的端口。 当我用netstat -antup | grep 3601查找我的gin服务启动的端口占用情况的时候发现&#xff0c;我的服务直接绑定了tcp6 &a…

240629_昇思学习打卡-Day11-Vision Transformer中的self-Attention

240629_昇思学习打卡-Day11-Transformer中的self-Attention 根据昇思课程顺序来看呢&#xff0c;今儿应该看Vision Transformer图像分类这里了&#xff0c;但是大概看了一下官方api&#xff0c;发现我还是太笨了&#xff0c;看不太明白。正巧昨天学SSD的时候不是参考了太阳花的…

LeetCode.30 串联所有单词的子串

问题描述 给定一个字符串 s 和一个字符串数组 words。 words 中所有字符串 长度相同。 s 中的 串联子串 是指一个包含 words 中所有字符串以任意顺序排列连接起来的子串。 例如&#xff0c;如果 words ["ab","cd","ef"]&#xff0c; 那么 &q…

MySQL Workbench支持哪些数据库版本的连接?

MySQL Workbench支持哪些数据库版本的连接&#xff1f; MySQL Workbench 是一款强大的数据库管理和设计工具&#xff0c;它支持连接多种版本的 MySQL 数据库。包括但不限于&#xff1a; MySQL 官方发行的所有版本&#xff0c;从 MySQL 5.0 到最新的 MySQL 8.x 和更高版本。 M…

Linux - 札记 - W10: Warning: Changing a readonly file

Linux - 札记 - W10: Warning: Changing a readonly file 这里写目录标题 一、问题描述1. 现象2. 原因 二、解决方案 一、问题描述 1. 现象 在使用 vim 编辑文件时&#xff08;我这里是要编辑 /root/.ssh/authorized_keys&#xff09;提示&#xff1a;W10: Warning: Changing…

【论文+代码|已完结】基于人工智能的图像识别技术在医疗诊断中的应用

基于人工智能的图像识别技术在医疗诊断中的应用 摘要&#xff1a;随着人工智能技术的飞速发展&#xff0c;图像识别技术在医疗领域的应用日益广泛。本毕业设计旨在研究基于人工智能的图像识别技术在医疗诊断中的应用&#xff0c;通过对大量医疗图像数据的分析和处理&#xff0…

IOS Swift 从入门到精通:ios 连接数据库 安装 Firebase 和 Firestore

创建 Firebase 项目 导航到Firebase 控制台并创建一个新项目。为项目指定任意名称。 在这里插入图片描述 下一步,启用 Google Analytics,因为我们稍后会用到它来发送推送通知。 在这里插入图片描述 在下一个屏幕上,选择您的 Google Analytics 帐户(如果已创建)。如果没…

<电力行业> - 《第7课:发电》

1 发电的原理 电力生产的发电环节是利用电能生产设备将各种一次能源或其他形式的能转换为电能。生产电能的主要方式有火力发电、水力发电、核能发电、地热发电、风力发电、太阳能发电、潮汐能发电、生物智能发电和燃料电池发电等。 除太阳能发电的光伏电池技术和燃料电池发电…

c++ 子类继承父类

这个是子类继承父类 是否重写从父类那里继承来的函数 这个例子的路径 E盘 demo文件夹 fatherChildfunc