多线程(四)——重入锁和读写锁以及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

相关文章

PostgreSQL中MVCC 机制的实现

《PostgreSQL中MVCC机制的实现》本文主要介绍了PostgreSQL中MVCC机制的实现,通过多版本数据存储、快照隔离和事务ID管理实现高并发读写,具有一定的参考价值,感兴趣的可以了解一下... 目录一 MVCC 基本原理python1.1 MVCC 核心概念1.2 与传统锁机制对比二 Postg

Maven 配置中的 <mirror>绕过 HTTP 阻断机制的方法

《Maven配置中的<mirror>绕过HTTP阻断机制的方法》:本文主要介绍Maven配置中的<mirror>绕过HTTP阻断机制的方法,本文给大家分享问题原因及解决方案,感兴趣的朋友一... 目录一、问题场景:升级 Maven 后构建失败二、解决方案:通过 <mirror> 配置覆盖默认行为1. 配置示

Redis过期删除机制与内存淘汰策略的解析指南

《Redis过期删除机制与内存淘汰策略的解析指南》在使用Redis构建缓存系统时,很多开发者只设置了EXPIRE但却忽略了背后Redis的过期删除机制与内存淘汰策略,下面小编就来和大家详细介绍一下... 目录1、简述2、Redis http://www.chinasem.cn的过期删除策略(Key Expir

Go语言中Recover机制的使用

《Go语言中Recover机制的使用》Go语言的recover机制通过defer函数捕获panic,实现异常恢复与程序稳定性,具有一定的参考价值,感兴趣的可以了解一下... 目录引言Recover 的基本概念基本代码示例简单的 Recover 示例嵌套函数中的 Recover项目场景中的应用Web 服务器中

ShardingSphere之读写分离方式

《ShardingSphere之读写分离方式》:本文主要介绍ShardingSphere之读写分离方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录ShardingSphere-读写分离读写分离mysql主从集群创建 user 表主节点执行见表语句项目代码读写分

Jvm sandbox mock机制的实践过程

《Jvmsandboxmock机制的实践过程》:本文主要介绍Jvmsandboxmock机制的实践过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、背景二、定义一个损坏的钟1、 Springboot工程中创建一个Clock类2、 添加一个Controller

python多线程并发测试过程

《python多线程并发测试过程》:本文主要介绍python多线程并发测试过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、并发与并行?二、同步与异步的概念?三、线程与进程的区别?需求1:多线程执行不同任务需求2:多线程执行相同任务总结一、并发与并行?1、

Golang实现Redis分布式锁(Lua脚本+可重入+自动续期)

《Golang实现Redis分布式锁(Lua脚本+可重入+自动续期)》本文主要介绍了Golang分布式锁实现,采用Redis+Lua脚本确保原子性,持可重入和自动续期,用于防止超卖及重复下单,具有一定... 目录1 概念应用场景分布式锁必备特性2 思路分析宕机与过期防止误删keyLua保证原子性可重入锁自动

Dubbo之SPI机制的实现原理和优势分析

《Dubbo之SPI机制的实现原理和优势分析》:本文主要介绍Dubbo之SPI机制的实现原理和优势,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Dubbo中SPI机制的实现原理和优势JDK 中的 SPI 机制解析Dubbo 中的 SPI 机制解析总结Dubbo中

Java 的 Condition 接口与等待通知机制详解

《Java的Condition接口与等待通知机制详解》在Java并发编程里,实现线程间的协作与同步是极为关键的任务,本文将深入探究Condition接口及其背后的等待通知机制,感兴趣的朋友一起看... 目录一、引言二、Condition 接口概述2.1 基本概念2.2 与 Object 类等待通知方法的区别