Java并发编程实战 04死锁了怎么办?

简介:

Java并发编程实战 04死锁了怎么办?

Java并发编程文章系列#
Java并发编程实战 01并发编程的Bug源头
Java并发编程实战 02Java如何解决可见性和有序性问题
Java并发编程实战 03互斥锁 解决原子性问题

前提#
在第三篇文章最后的例子当中,需要获取到两个账户的锁后进行转账操作,这种情况有可能会发生死锁,我把上一章的代码片段放到下面:

Copy
public class Account {

// 余额
private Long money;
public synchronized void transfer(Account target, Long money) {
    synchronized(this) {           (1)
        synchronized (target) {    (2)
            this.money -= money;
            if (this.money < 0) {
                // throw exception
            }
            target.money += money;
        }
    }
}

}
若账户A转账给账户B100元,账户B同时也转账给账户A100元,当账户A转帐的线程A执行到了代码(1)处时,获取到了账户A对象的锁,同时账户B转账的线程B也执行到了代码(1)处时,获取到了账户B对象的锁。当线程A和线程B执行到了代码(2)处时,他们都在互相等待对方释放锁来获取,可是synchronized是阻塞锁,没有执行完代码块是不会释放锁的,就这样,线程A和线程B死死的对着,谁也不放过谁。等到了你去重启应用的那一天。。。这个现象就是死锁。
死锁的定义:一组互相竞争资源的线程因互相等待,导致“永久”阻塞的现象。
如下图:

查找死锁信息#
这里我先以一个基本会发生死锁的程序为例,创建两个线程,线程A获取到锁A后,休眠1秒后去获取锁B;线程B获取到锁B后 ,休眠1秒后去获取锁A。那么这样基本都会发生死锁的现象,代码如下:

Copy
public class DeadLock extends Thread {

private String first;
private String second;
public DeadLock(String name, String first, String second) {
    super(name); // 线程名
    this.first = first;
    this.second = second;
}

public  void run() {
    synchronized (first) {
        System.out.println(this.getName() + " 获取到锁: " + first);
        try {
            Thread.sleep(1000L); //线程休眠1秒
            synchronized (second) {
                System.out.println(this.getName() + " 获取到锁: " + second);
            }
        } catch (InterruptedException e) {
            // Do nothing
        }
    }
}
public static void main(String[] args) throws InterruptedException {
    String lockA = "lockA";
    String lockB = "lockB";
    DeadLock threadA = new DeadLock("ThreadA", lockA, lockB);
    DeadLock threadB = new DeadLock("ThreadB", lockB, lockA);
    threadA.start();
    threadB.start();
    threadA.join(); //等待线程1执行完
    threadB.join();
}

}
运行程序后将发生死锁,然后使用jps命令(jps.exe在jdk/bin目录下),命令如下:

Copy
C:Program FilesJavajdk1.8.0_221bin>jps -l
24416 sun.tools.jps.Jps
24480 org.jetbrains.kotlin.daemon.KotlinCompileDaemon
1624
20360 org.jetbrains.jps.cmdline.Launcher
9256
9320 page2.DeadLock
18188
可以发现发生死锁的进程id 9320,然后使用jstack(jstack.exe在jdk/bin目录下)命令查看死锁信息。

Copy
C:Program FilesJavajdk1.8.0_221bin>jstack 9320
"ThreadB" #13 prio=5 os_prio=0 tid=0x000000001e48c800 nid=0x51f8 waiting for monitor entry [0x000000001f38f000]
java.lang.Thread.State: BLOCKED (on object monitor)

    at page2.DeadLock.run(DeadLock.java:19)
    - waiting to lock <0x000000076b99c198> (a java.lang.String)
    - locked <0x000000076b99c1d0> (a java.lang.String)

"ThreadA" #12 prio=5 os_prio=0 tid=0x000000001e48c000 nid=0x3358 waiting for monitor entry [0x000000001f28f000]
java.lang.Thread.State: BLOCKED (on object monitor)

    at page2.DeadLock.run(DeadLock.java:19)
    - waiting to lock <0x000000076b99c1d0> (a java.lang.String)
    - locked <0x000000076b99c198> (a java.lang.String)

这样我们就可以看到发生死锁的信息。虽然发现了死锁,但是解决死锁只能是重启应用了。

如何避免死锁的发生#
1.固定的顺序来获得锁#
如果所有线程以固定的顺序来获得锁,那么在程序中就不会出现锁顺序死锁问题。(取自《Java并发编程实战》一书)
要想验证锁顺序的一致性,有很多种方式,如果锁定的对象含有递增的id字段(唯一、不可变、具有可比性的),那么就好办多了,获取锁的顺序以id由小到大来排序。还是用转账的例子来解释,代码如下:

Copy
public class Account {

// id (递增)
private Integer id;
// 余额
private Long money;
public synchronized void transfer(Account target, Long money) {
    Account account1;
    Account account2;
    if (this.id < target.id) {
        account1 = this;
        account2 = target;
    } else {
        account1 = target;
        account2 = this;
    }

    synchronized(account1) {
        synchronized (account2) {
            this.money -= money;
            if (this.money < 0) {
                // throw exception
            }
            target.money += money;
        }
    }
}

}
若该对象并没有唯一、不可变、具有可比性的的字段(如:递增的id),那么可以使用 System.identityHashCode() 方法返回的哈希值来进行比较。比较方式可以和上面的例子一类似。System.identityHashCode()虽然会出现散列冲突,但是发生冲突的概率是非常低的。因此这项技术以最小的代价,换来了最大的安全性。
提示: 不管你是否重写了对象的hashCode方法,System.identityHashCode() 方法都只会返回默认的哈希值。

2.一次性申请所有资源#
只要同时获取到转出账户和转入账户的资源锁。执行完转账操作后,也同时释放转入账户和转出账户的资源锁。那么则不会出现死锁。但是使用synchronized只能同时锁定一个资源锁,所以需要建立一个锁分配器LockAllocator。代码如下:

Copy
/* 锁分配器(单例类) /
public class LockAllocator {

private final List<Object> lock = new ArrayList<Object>();
/** 同时申请锁资源 */
public synchronized boolean lock(Object object1, Object object2) {
    if (lock.contains(object1) || lock.contains(object2)) {
        return false;
    }

    lock.add(object1);
    lock.add(object2);
    return true;
}
/** 同时释放资源锁 */
public synchronized void unlock(Object object1, Object object2) {
    lock.remove(object1);
    lock.remove(object2);
}

}

public class Account {

// 余额
private Long money;
// 锁分配器
private LockAllocator lockAllocator;

public void transfer(Account target, Long money) {
    try {
        // 循环获取锁,直到获取成功
        while (!lockAllocator.lock(this, target)) {
        }

        synchronized (this){
            synchronized (target){
                this.money -= money;
                if (this.money < 0) {
                    // throw exception
                }
                target.money += money;
            }
        }
    } finally {
        // 释放锁
        lockAllocator.unlock(this, target);
    }
}

}
使用while循环不断的去获取锁,一直到获取成功,当然你也可以设置获取失败后休眠xx毫秒后获取,或者其他优化的方式。释放锁必须使用try-finally的方式来释放锁。避免释放锁失败。

3.尝试获取锁资源#
在Java中,Lock接口定义了一组抽象的加锁操作。与内置锁synchronized不同,使用内置锁时,只要没有获取到锁,就会死等下去,而显示锁Lock提供了一种无条件的、可轮询的、定时的以及可中断的锁获取操作,所有加锁和解锁操作都是显示的(内置锁synchronized的加锁和解锁操作都是隐示的),这篇文章就不展开来讲显示锁Lock了(当然感兴趣的朋友可以先百度一下)。

总结#
在生产环境发生死锁可是一个很严重的问题,虽说重启应用来解决死锁,但是毕竟是生产环境,代价很大,而且重启应用后还是可能会发生死锁,所以在编写并发程序时需要非常严谨的避免死锁的发生。避免死锁的方案应该还有更多,鄙人不才,暂知这些方案。若有其它方案可以留言告知。非常感谢你的阅读,谢谢。

参考文章:
《Java并发编程实战》第10章
极客时间:Java并发编程实战 05:一不小心死锁了,怎么办?
极客时间:Java核心技术面试精讲 18:什么情况下Java程序会产生死锁?如何定位、修复?

如果我的文章帮助到您,可以关注我的微信公众号,第一时间分享文章给您

作者: Johnson木木

出处:https://www.cnblogs.com/Johnson-lin/p/12874009.html

相关文章
|
25天前
|
安全 Java 数据库连接
2025 年最新 Java 学习路线图含实操指南助你高效入门 Java 编程掌握核心技能
2025年最新Java学习路线图,涵盖基础环境搭建、核心特性(如密封类、虚拟线程)、模块化开发、响应式编程、主流框架(Spring Boot 3、Spring Security 6)、数据库操作(JPA + Hibernate 6)及微服务实战,助你掌握企业级开发技能。
196 3
|
30天前
|
Java 关系型数据库 数据库
Java 项目实战教程从基础到进阶实战案例分析详解
本文介绍了多个Java项目实战案例,涵盖企业级管理系统、电商平台、在线书店及新手小项目,结合Spring Boot、Spring Cloud、MyBatis等主流技术,通过实际应用场景帮助开发者掌握Java项目开发的核心技能,适合从基础到进阶的学习与实践。
190 3
|
1月前
|
缓存 前端开发 Java
基于最新 Java 技术栈的在线任务管理系统开发实战详解
本项目基于最新Java技术栈开发在线任务管理系统,涵盖任务创建、分配、跟踪、统计等功能。采用Spring Boot 3.2.x、React 18、PostgreSQL 16等主流技术,详解项目架构设计、核心功能实现及部署流程,助力掌握现代Java全栈开发技能。
123 6
|
29天前
|
Java API Maven
2025 Java 零基础到实战最新技术实操全攻略与学习指南
本教程涵盖Java从零基础到实战的全流程,基于2025年最新技术栈,包括JDK 21、IntelliJ IDEA 2025.1、Spring Boot 3.x、Maven 4及Docker容器化部署,帮助开发者快速掌握现代Java开发技能。
295 1
|
1月前
|
消息中间件 Java Kafka
Java 事件驱动架构设计实战与 Kafka 生态系统组件实操全流程指南
本指南详解Java事件驱动架构与Kafka生态实操,涵盖环境搭建、事件模型定义、生产者与消费者实现、事件测试及高级特性,助你快速构建高可扩展分布式系统。
147 7
|
1月前
|
消息中间件 Java 数据库
Java 基于 DDD 分层架构实战从基础到精通最新实操全流程指南
本文详解基于Java的领域驱动设计(DDD)分层架构实战,结合Spring Boot 3.x、Spring Data JPA 3.x等最新技术栈,通过电商订单系统案例展示如何构建清晰、可维护的微服务架构。内容涵盖项目结构设计、各层实现细节及关键技术点,助力开发者掌握DDD在复杂业务系统中的应用。
277 0
|
1月前
|
算法 Java 开发者
Java 项目实战数字华容道与石头迷阵游戏开发详解及实战方法
本文介绍了使用Java实现数字华容道和石头迷阵游戏的技术方案与应用实例,涵盖GUI界面设计、二维数组操作、游戏逻辑控制及自动解法算法(如A*),适合Java开发者学习游戏开发技巧。
184 46
|
1月前
|
监控 Kubernetes Java
最新技术栈驱动的 Java 绿色计算与性能优化实操指南涵盖内存优化与能效提升实战技巧
本文介绍了基于Java 24+技术栈的绿色计算与性能优化实操指南。主要内容包括:1)JVM调优,如分代ZGC配置和结构化并发优化;2)代码级优化,包括向量API加速数据处理和零拷贝I/O;3)容器化环境优化,如K8s资源匹配和节能模式配置;4)监控分析工具使用。通过实践表明,这些优化能显著提升性能(响应时间降低40-60%)同时降低资源消耗(内存减少30-50%,CPU降低20-40%)和能耗(服务器功耗减少15-35%)。建议采用渐进式优化策略。
110 1
|
1月前
|
Java
Java编程:理解while循环的使用
总结而言, 使用 while 迴圈可以有效解决需要多次重复操作直至特定條件被触发才停止執行任务场景下问题; 它简单、灵活、易于实现各种逻辑控制需求但同时也要注意防止因邏各错误导致無限迁璇発生及及時處理可能発生异常以确保程序稳定运作。
164 0
|
1月前
|
人工智能 自然语言处理 分布式计算
AI 驱动传统 Java 应用集成的关键技术与实战应用指南
本文探讨了如何将AI技术与传统Java应用集成,助力企业实现数字化转型。内容涵盖DJL、Deeplearning4j等主流AI框架选择,技术融合方案,模型部署策略,以及智能客服、财务审核、设备诊断等实战应用案例,全面解析Java系统如何通过AI实现智能化升级与效率提升。
176 0