死锁终结者:顺序锁和轮询锁!

作者 | 王磊

来源 | Java中文社群(ID:javacn666)

转载请联系授权(微信ID:GG_Stone

死锁(Dead Lock)指的是两个或两个以上的运算单元(进程、线程或协程),都在等待对方停止执行,以取得系统资源,但是没有一方提前退出,就称为死锁。

死锁示例代码如下:

public class DeadLockExample {public static void main(String[] args) {Object lockA = new Object(); // 创建锁 AObject lockB = new Object(); // 创建锁 B// 创建线程 1Thread t1 = new Thread(new Runnable() {@Overridepublic void run() {synchronized (lockA) {System.out.println("线程 1:获取到锁 A!");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("线程 1:等待获取 B...");synchronized (lockB) {System.out.println("线程 1:获取到锁 B!");}}}});t1.start(); // 运行线程// 创建线程 2Thread t2 = new Thread(new Runnable() {@Overridepublic void run() {synchronized (lockB) {System.out.println("线程 2:获取到锁 B!");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("线程 2:等待获取 A...");synchronized (lockA) {System.out.println("线程 2:获取到锁 A!");}}}});t2.start(); // 运行线程}
}

以上程序的执行结果如下:

从上述结果可以看出,线程 1 和线程 2 都进入了死锁状态,相互都在等待对方释放锁。

从上述示例分析可以得出,产生死锁需要满足以下 4 个条件:

  1. 互斥条件:指运算单元(进程、线程或协程)对所分配到的资源具有排它性,也就是说在一段时间内某个锁资源只能被一个运算单元所占用。

  2. 请求和保持条件:指运算单元已经保持至少一个资源,但又提出了新的资源请求,而该资源已被其它运算单元占有,此时请求运算单元阻塞,但又对自己已获得的其它资源保持不放。

  3. 不可剥夺条件:指运算单元已获得的资源,在未使用完之前,不能被剥夺。

  4. 环路等待条件:指在发生死锁时,必然存在运算单元和资源的环形链,即运算单元正在等待另一个运算单元占用的资源,而对方又在等待自己占用的资源,从而造成环路等待的情况。

只有这 4 个条件同时满足,才会造成死锁的问题。

那么也就是说,要产生死锁必须要同时满足以上 4 个条件才行,那我们就可以通过破坏任意一个条件来解决死锁问题了。

死锁解决方案分析

接下来我们来分析一下,产生死锁的 4 个条件,哪些是可以破坏的?哪些是不能被破坏的?

  • 互斥条件:系统特性,不能被破坏。

  • 请求和保持条件:可以被破坏。

  • 不可剥夺条件:系统特性,不能被破坏。

  • 环路等待条件:可以被破坏。

通过上述分析,我们可以得出结论,我们只能通过破坏请求和保持条件或者是环路等待条件,从而来解决死锁的问题,那上线,我们就先从破坏“环路等待条件”开始来解决死锁问题。

解决方案1:顺序锁

所谓的顺序锁指的是通过有顺序的获取锁,从而避免产生环路等待条件,从而解决死锁问题的。

当我们没有使用顺序锁时,程序的执行可能是这样的:

线程 1 先获取了锁 A,再获取锁 B,线程 2 与 线程 1 同时执行,线程 2 先获取锁 B,再获取锁 A,这样双方都先占用了各自的资源(锁 A 和锁 B)之后,再尝试获取对方的锁,从而造成了环路等待问题,最后造成了死锁的问题。

此时我们只需要将线程 1 和线程 2 获取锁的顺序进行统一,也就是线程 1 和线程 2 同时执行之后,都先获取锁 A,再获取锁 B,执行流程如下图所示:

因为只有一个线程能成功获取到锁 A,没有获取到锁 A 的线程就会等待先获取锁 A,此时得到锁 A 的线程继续获取锁 B,因为没有线程争抢和拥有锁 B,那么得到锁 A 的线程就会顺利的拥有锁 B,之后执行相应的代码再将锁资源全部释放,然后另一个等待获取锁 A 的线程就可以成功获取到锁资源,执行后续的代码,这样就不会出现死锁的问题了。

顺序锁的实现代码如下所示:

public class SolveDeadLockExample {public static void main(String[] args) {Object lockA = new Object(); // 创建锁 AObject lockB = new Object(); // 创建锁 B// 创建线程 1Thread t1 = new Thread(new Runnable() {@Overridepublic void run() {synchronized (lockA) {System.out.println("线程 1:获取到锁 A!");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("线程 1:等待获取 B...");synchronized (lockB) {System.out.println("线程 1:获取到锁 B!");}}}});t1.start(); // 运行线程// 创建线程 2Thread t2 = new Thread(new Runnable() {@Overridepublic void run() {synchronized (lockA) {System.out.println("线程 2:获取到锁 A!");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("线程 2:等待获取B...");synchronized (lockB) {System.out.println("线程 2:获取到锁 B!");}}}});t2.start(); // 运行线程}
}

以上程序的执行结果如下:

从上述执行结果可以看出,程序并没有出现死锁的问题。

解决方案2:轮询锁

轮询锁是通过打破“请求和保持条件”来避免造成死锁的,它的实现思路简单来说就是通过轮询来尝试获取锁,如果有一个锁获取失败,则释放当前线程拥有的所有锁,等待下一轮再尝试获取锁。

轮询锁的实现需要使用到 ReentrantLock 的 tryLock 方法,具体实现代码如下:

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;public class SolveDeadLockExample {public static void main(String[] args) {Lock lockA = new ReentrantLock(); // 创建锁 ALock lockB = new ReentrantLock(); // 创建锁 B// 创建线程 1(使用轮询锁)Thread t1 = new Thread(new Runnable() {@Overridepublic void run() {// 调用轮询锁pollingLock(lockA, lockB);}});t1.start(); // 运行线程// 创建线程 2Thread t2 = new Thread(new Runnable() {@Overridepublic void run() {lockB.lock(); // 加锁System.out.println("线程 2:获取到锁 B!");try {Thread.sleep(1000);System.out.println("线程 2:等待获取 A...");lockA.lock(); // 加锁try {System.out.println("线程 2:获取到锁 A!");} finally {lockA.unlock(); // 释放锁}} catch (InterruptedException e) {e.printStackTrace();} finally {lockB.unlock(); // 释放锁}}});t2.start(); // 运行线程}/*** 轮询锁*/public static void pollingLock(Lock lockA, Lock lockB) {while (true) {if (lockA.tryLock()) { // 尝试获取锁System.out.println("线程 1:获取到锁 A!");try {Thread.sleep(1000);System.out.println("线程 1:等待获取 B...");if (lockB.tryLock()) { // 尝试获取锁try {System.out.println("线程 1:获取到锁 B!");} finally {lockB.unlock(); // 释放锁System.out.println("线程 1:释放锁 B.");break;}}} catch (InterruptedException e) {e.printStackTrace();} finally {lockA.unlock(); // 释放锁System.out.println("线程 1:释放锁 A.");}}// 等待一秒再继续执行try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}
}

以上程序的执行结果如下:

从上述结果可以看出,以上代码也没有出现死锁的问题。

总结

本文介绍了解决死锁的 2 种方案:

  • 第 1 种顺序锁:通过改变获取锁的顺序也就打破“环路请求条件”来避免死锁问题的发生;

  • 第 2 种轮询锁:通过轮询的方式也就是打破“请求和拥有条件”来解决死锁问题。它的实现思路是,通过自旋的方式来尝试获取锁,在获取锁的途中,如果有任何一个锁获取失败,则释放之前获取的所有锁,等待一段时间之后再次执行之前的流程,这样就避免一个锁一直被(一个线程)占用的尴尬了,从而避免了死锁问题。

参考 & 鸣谢

《Java并发编程实战》


原创并发文章推荐

1.线程的故事:我的3位母亲成就了优秀的我!

2.线程池的7种创建方式,强烈推荐你用它...

3.轻量级锁一定比重量级锁快吗?

4.这样终止线程,竟然会导致服务宕机?

5.漫画:如何证明sleep不释放锁,而wait释放锁?

6.池化技术到达有多牛?看了这个对比吓我一跳!

7.求求你,别再用wait和notify了!

8.Semaphore自白:限流器用我就对了!

9.CountDownLatch:别浪,等人齐再团!

10.CyclicBarrier:人齐了,老司机就发车了!

11.Java中用户线程和守护线程区别这么大?

12.ThreadLocal不好用?那是你没用对!

13.ThreadLocal内存溢出代码演示和原因分析!

14.SimpleDateFormat线程不安全的5种解决方案!

15.synchronized 加锁 this 和 class 的区别!

16.synchronized 优化手段之锁膨胀机制!

17.synchronized 中的 4 个优化,你知道几个?

18.ReentrantLock 中的 4 个坑!

19.图解:为什么非公平锁的性能更高?

20.死锁的 4 种排查工具 !


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

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

相关文章

Nginx For Windows HTTP转发和负载

Nginx For Windows HTTP转发和负载一、需求说明二、配置文件一、需求说明 使用Nginx进行端口转发,并且负载到两台服务器的服务上。 监控本地服务器的 9099 端口,转发并负载到 127.0.0.1:9001 和 127.0.0.1:9002 服务上。(可以选择只转发到一…

Java PushbackReader mark()方法与示例

PushbackReader类mark()方法 (PushbackReader Class mark() method) mark() method is available in java.io package. mark()方法在java.io包中可用。 mark() method is used to mark the current position in this stream and this method throws an exception during the ca…

轮询锁使用时遇到的问题与解决方案!

作者 | 王磊来源 | Java中文社群(ID:javacn666)转载请联系授权(微信ID:GG_Stone当我们遇到死锁之后,除了可以手动重启程序解决之外,还可以考虑是使用顺序锁和轮询锁,这部分的内容可以…

DHCP 日志分析

DHCP 日志分析 DHCP(Dynamic Host Configuration Protocol,动态主机配置协议)是一种有效的IP 地址分配手段,现已经被广泛地应用在各种局域网管理。它能动态地向网络中每台计算机分配唯一的IP 地址,并提供安全、可靠、简…

Nginx For Windows Socket 端口转发

Nginx For Windows Socket 端口转发一、需求说明二、配置文件一、需求说明 使用Nginx进行端口转发 Socket 端口通信。 监控本地服务器的 3001 端口,转发到 10.73.60.48:3001 服务器上的 Socket 端口服务。 二、配置文件 完整配置文件如下,测试可用 #…

16 条 yyds 的代码规范

作者 | 涛姐涛哥链接 | cnblogs.com/taojietaoge/p/11575376.html背景:如何更规范化编写Java 代码的重要性想必毋需多言,其中最重要的几点当属提高代码性能、使代码远离Bug、令代码更优雅。一、MyBatis 不要为了多个查询条件而写 1 1当遇到多个查询条件…

linkedhashset_Java LinkedHashSet clear()方法与示例

linkedhashsetLinkedHashSet类的clear()方法 (LinkedHashSet Class clear() method) clear() method is available in java.util package. clear()方法在java.util包中可用。 clear() method is used to clear all of the existing objects in this LinkedHashSet. clear()方法…

C# 导出word文档及批量导出word文档(3)

在初始化WordHelper时,要获取模板的相对路径。获取文档的相对路径多个地方要用到,比如批量导出时要先保存文件到指定路径下,再压缩打包下载,所以专门写了个关于获取文档的相对路径的类。 1 #region 获取文档的相对路径2 pub…

Nginx For Windows 路由配置

Nginx For Windows 路由配置一、路由配置说明二、需求说明三、配置文件一、路由配置说明 使用Nginx进行路由配置。 使用过 SpringCloud 网关的同学都知道,网关可以使用同一IP地址、同一端口号、不同的服务ID,转发不同服务API信息,不会出现跨…

再见收费的 XShell,我改用国产良心工具!

使用或维护Linux系统的都知道,我们日常对服务器的操作,一般都会借助SSH工具远程登录到服务器之后进行操作。常用的SSH工具有不少,比如:Xshell、Putty、SSH Secure Shell Client、secureCRT等等。我使用过其中两种secureCRT和Xshel…

Java IdentityHashMap put()方法与示例

IdentityHashMap类的put()方法 (IdentityHashMap Class put() method) put() method is available in java.util package. put()方法在java.util包中可用。 put() method is used to set the given value element (val_ele) with the given key element (key_ele) when no valu…

全球六大国际域名解析量统计报告(6月25日)

IDC评述网(idcps.com)06月29日报道:根据DailyChanges公布的实时数据显示,在2015年6月25日,全球六大国际域名解析量总量持续攀升至153,246,819个,环比6月16日,净增46,078个,涨幅增大3…

Windows 创建符号链接

一、场景分析 1.环境变量 在Windows系统配置 环境变量 的时候,经常会遇到以下 路径 情况: C:\Program Files C:\Program Files (x86)\Common Files2.异常情况 这种路径中,存在空格字符,在一些程序调用时,可能出现异…

1.3w字,一文详解死锁!

作者 | 王磊来源 | Java中文社群(ID:javacn666)转载请联系授权(微信ID:GG_Stone死锁(Dead Lock)指的是两个或两个以上的运算单元(进程、线程或协程),都在等待…

Java Dictionary elements()方法与示例

字典类的elements()方法 (Dictionary Class elements() method) elements() method is available in java.util package. elements()方法在java.util包中可用。 elements() method is used to get the elements of an Enumeration in this dictionary. elements()方法用于获取此…

PHP与ThinkPHP读写文件

2019独角兽企业重金招聘Python工程师标准>>> 使用php将数据写入到指定的文件 $str"<?php return".var_export($phiz,true)."?>"; file_put_contents(./Data/phiz.php); 使用php读取指定的文件 …

软件版本号设置规则及示例

一、版本号设置规则 ABC客户端 版本说明书 [版本命名规则] 如&#xff1a;1.0.0.0 位数名称描述情景第一位主版本重大修改&#xff0c;重写或里程碑[里程碑] [重大更新]第二位次版本显著增强、功能变更较多[新增功能] [删减功能]第三位生成号功能变更&#xff0c;局部修正较多…

【图解】透彻Java线程状态转换

大家好&#xff0c;我是阿星&#xff0c;好久不见&#xff0c;欢迎来到Java并发编程系列番外篇线程状态转换&#xff0c;内容通俗易懂&#xff0c;请放心食用。线程状态先来个开场四连问Java线程状态有几个&#xff1f;Java线程状态是如何转换&#xff1f;Java线程状态转换什么…

Java Byte类的hashCode()方法及示例

短类hashCode()方法 (Short class hashCode() method) hashCode() method is available in java.lang package. hashCode()方法在java.lang包中可用。 hashCode() method is used to return hashcode of the Byte object. hashCode()方法用于返回Byte对象的哈希码。 hashCode()…

CentOS7安装Hadoop2.7完整流程

2019独角兽企业重金招聘Python工程师标准>>> 1、环境&#xff0c;3台CentOS7&#xff0c;64位&#xff0c;Hadoop2.7需要64位Linux&#xff0c;CentOS7 Minimal的ISO文件只有600M&#xff0c;操作系统十几分钟就可以安装完成&#xff0c; Master 192.168.0.182 Slav…