多线程(四)——重入锁和读写锁以及CAS无锁机制

2024-02-23 06:32

本文主要是介绍多线程(四)——重入锁和读写锁以及CAS无锁机制,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

概念:

1、在java环境下ReentrantLock和synchronized都是可重入锁
2、非重入锁会导致死锁
3、重入锁,传递给下一个方法,重复使用

重入锁测试代码:

package thread.pool;/*** 重入锁、非重入锁* @author Administrator**/
public class Test5 implements Runnable {public synchronized void get(){System.out.println(Thread.currentThread().getId() +"---get()");set();}public synchronized void set(){System.out.println(Thread.currentThread().getId() +"---set()");}@Overridepublic void run() {get();}public static void main(String[] args) {Test5 th = new Test5();new Thread(th).start();new Thread(th).start();new Thread(th).start();new Thread(th).start();new Thread(th).start();}
}
package thread.pool;import java.util.concurrent.locks.ReentrantLock;/*** 重入锁、非重入锁* @author Administrator**/
public class Test6 implements Runnable {ReentrantLock dd = new ReentrantLock();public void get(){dd.lock();System.out.println(Thread.currentThread().getId() +"---get()");set();dd.unlock();}public void set(){dd.lock();System.out.println(Thread.currentThread().getId() +"---set()");dd.unlock();}@Overridepublic void run() {get();}public static void main(String[] args) {Test6 th = new Test6();new Thread(th).start();new Thread(th).start();new Thread(th).start();new Thread(th).start();new Thread(th).start();}
}

读写锁的测试代码:

package thread.pool;import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantReadWriteLock;/*** * 读写锁* * @author Administrator**/
public class Test7 {static Map<String, Object> map = new HashMap<>();static ReentrantReadWriteLock da = new ReentrantReadWriteLock();static Lock r = da.readLock();static Lock w = da.writeLock();public static void get(String key) {r.lock();System.out.println(""+key+"正在进行----读----操作-----开始");try {Thread.sleep(100);Object object = map.get(key);System.out.println(""+key+"-"+object+"正在进行----读---操作-----结束");} catch (InterruptedException e) {e.printStackTrace();}finally {r.unlock();}}public static void set(String key, String value) {w.lock();System.out.println(""+key+"-"+value+"正在进行----写----操作-----开始");try {Thread.sleep(100);map.put(key, value);System.out.println(""+key+"-"+value+"正在进行----写----操作-----结束");} catch (InterruptedException e) {e.printStackTrace();}finally {w.unlock();}}public static void main(String[] args) {new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {Test7.get(i+"");}}}).start();new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {Test7.set(i+"", i+"");}}}).start();}
}

4、CAS无锁机制
举例:原子类底层实现保证线程安全,就是采用CAS无锁机制,CAS无锁机制效率比有效机制高
5、CAS体系中有三个参数,它包含三个参数CAS(V,E,N):v表示要更新的变量值,E表示预期值,N表示新值。仅当V值等于E值时,才会将V的值设为N,如果V值和E值不同,则说明已经有其他线程做了更新,则当前线程什么都不会做。最后,CAS返回当前V的真实值

 

这篇关于多线程(四)——重入锁和读写锁以及CAS无锁机制的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/737788

相关文章

JAVA实现Token自动续期机制的示例代码

《JAVA实现Token自动续期机制的示例代码》本文主要介绍了JAVA实现Token自动续期机制的示例代码,通过动态调整会话生命周期平衡安全性与用户体验,解决固定有效期Token带来的风险与不便,感兴... 目录1. 固定有效期Token的内在局限性2. 自动续期机制:兼顾安全与体验的解决方案3. 总结PS

C++读写word文档(.docx)DuckX库的使用详解

《C++读写word文档(.docx)DuckX库的使用详解》DuckX是C++库,用于创建/编辑.docx文件,支持读取文档、添加段落/片段、编辑表格,解决中文乱码需更改编码方案,进阶功能含文本替换... 目录一、基本用法1. 读取文档3. 添加段落4. 添加片段3. 编辑表格二、进阶用法1. 文本替换2

详解Spring中REQUIRED事务的回滚机制详解

《详解Spring中REQUIRED事务的回滚机制详解》在Spring的事务管理中,REQUIRED是最常用也是默认的事务传播属性,本文就来详细的介绍一下Spring中REQUIRED事务的回滚机制,... 目录1. REQUIRED 的定义2. REQUIRED 下的回滚机制2.1 异常触发回滚2.2 回

SpringBoot分段处理List集合多线程批量插入数据方式

《SpringBoot分段处理List集合多线程批量插入数据方式》文章介绍如何处理大数据量List批量插入数据库的优化方案:通过拆分List并分配独立线程处理,结合Spring线程池与异步方法提升效率... 目录项目场景解决方案1.实体类2.Mapper3.spring容器注入线程池bejsan对象4.创建

ShardingProxy读写分离之原理、配置与实践过程

《ShardingProxy读写分离之原理、配置与实践过程》ShardingProxy是ApacheShardingSphere的数据库中间件,通过三层架构实现读写分离,解决高并发场景下数据库性能瓶... 目录一、ShardingProxy技术定位与读写分离核心价值1.1 技术定位1.2 读写分离核心价值二

基于Redis自动过期的流处理暂停机制

《基于Redis自动过期的流处理暂停机制》基于Redis自动过期的流处理暂停机制是一种高效、可靠且易于实现的解决方案,防止延时过大的数据影响实时处理自动恢复处理,以避免积压的数据影响实时性,下面就来详... 目录核心思路代码实现1. 初始化Redis连接和键前缀2. 接收数据时检查暂停状态3. 检测到延时过

Redis中哨兵机制和集群的区别及说明

《Redis中哨兵机制和集群的区别及说明》Redis哨兵通过主从复制实现高可用,适用于中小规模数据;集群采用分布式分片,支持动态扩展,适合大规模数据,哨兵管理简单但扩展性弱,集群性能更强但架构复杂,根... 目录一、架构设计与节点角色1. 哨兵机制(Sentinel)2. 集群(Cluster)二、数据分片

Python多线程实现大文件快速下载的代码实现

《Python多线程实现大文件快速下载的代码实现》在互联网时代,文件下载是日常操作之一,尤其是大文件,然而,网络条件不稳定或带宽有限时,下载速度会变得很慢,本文将介绍如何使用Python实现多线程下载... 目录引言一、多线程下载原理二、python实现多线程下载代码说明:三、实战案例四、注意事项五、总结引

Python多线程应用中的卡死问题优化方案指南

《Python多线程应用中的卡死问题优化方案指南》在利用Python语言开发某查询软件时,遇到了点击搜索按钮后软件卡死的问题,本文将简单分析一下出现的原因以及对应的优化方案,希望对大家有所帮助... 目录问题描述优化方案1. 网络请求优化2. 多线程架构优化3. 全局异常处理4. 配置管理优化优化效果1.

深入理解go中interface机制

《深入理解go中interface机制》本文主要介绍了深入理解go中interface机制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前言interface使用类型判断总结前言go的interface是一组method的集合,不