在大型分布式系统中，死锁是一种常见但难以排查的并发问题。特别是在 Java 领域，死锁问题可能导致系统崩溃或卡顿。本文将以电商交易系统为例，详细讲解如何识别和避免 Java 程序中的死锁问题，确保系统高效运行。
1. 什么是死锁？
死锁是指多个线程相互持有对方所需的资源，且都在等待对方释放资源的状态。此时，这些线程将永远无法继续执行，造成系统资源被占用，无法释放。
在 Java 中，死锁主要发生在 synchronized 块或锁（如 ReentrantLock）的使用中。当两个或多个线程在请求多个共享资源时，如果请求的顺序不一致，就可能导致死锁。
1.1 类图说明
死锁通常发生在多线程环境下，其中线程竞争同一个或多个资源，导致互相等待，进入“僵局”状态。我们可以通过一个简单的类图来展示两个线程和两个锁的相互依赖关系。
死锁类图
类图解释：
Thread1线程持有Lock1，并等待Lock2；Thread2线程持有Lock2，并等待Lock1；- 由于两个线程相互等待对方持有的锁，形成了死锁。
1.2 时序图说明
时序图可以更直观地展示死锁发生的过程。在下图中，两个线程分别尝试获取两把锁，结果导致相互等待。
死锁时序图
时序图解释：
Thread1首先获取Lock1，然后尝试获取Lock2，但此时Lock2被Thread2占用。Thread2获取了Lock2，但在尝试获取Lock1时，发现Lock1已经被Thread1占用。- 两个线程彼此等待对方释放锁，导致了死锁。
2. 如何检测死锁？
2.1 使用 JDK 自带的工具
2.1.1 jstack 工具
jstack 是 JDK 自带的工具，用于查看 Java 虚拟机中的线程堆栈。通过它，可以检查当前 JVM 中所有线程的状态，包括是否存在死锁。我们可以使用 jstack 来捕获线程状态，从中判断是否存在死锁。
使用步骤：
-
首先，找到正在运行的 JVM 进程 ID（PID）。可以使用
jps命令获取：
jps -
然后使用
jstack工具查看线程堆栈：
jstack <PID>
在输出的堆栈信息中，若某个线程显示为 waiting to lock，并且有多个线程都处于类似状态，则可能存在死锁问题。通过线程堆栈中的资源锁信息，可以定位到具体的死锁代码。
示例：
假设我们有一个电商系统中的库存和订单两个模块：
public class DeadlockExample {
private final Object lock1 = new Object();
private final Object lock2 = new Object();
public void method1() {
synchronized (lock1) {
System.out.println("Thread 1: Holding lock 1...");
try { Thread.sleep(100); } catch (InterruptedException e) {}
synchronized (lock2) {
System.out.println("Thread 1: Holding lock 2...");
}
}
}
public void method2() {
synchronized (lock2) {
System.out.println("Thread 2: Holding lock 2...");
try { Thread.sleep(100); } catch (InterruptedException e) {}
synchronized (lock1) {
System.out.println("Thread 2: Holding lock 1...");
}
}
}
public static void main(String[] args) {
DeadlockExample example = new DeadlockExample();
Thread t1 = new Thread(example::method1);
Thread t2 = new Thread(example::method2);
t1.start();
t2.start();
}
}
在上述代码中，method1 和 method2 中的锁请求顺序不同，可能导致死锁。执行 jstack 工具可以帮助我们确认这一死锁问题。
2.1.2 jconsole 工具
jconsole 是一个基于 GUI 的监控工具，能够直观地展示线程的运行状态。它提供了“线程”选项，可以查看每个线程的运行状况，并能检测到死锁。
使用步骤：
- 运行
jconsole，选择相应的 JVM 进程连接。 - 在工具中选择“线程”选项卡，查看线程堆栈及是否存在死锁。
2.2 使用代码检测
2.2.1 ThreadMXBean 类
Java 提供了 ThreadMXBean 类来检测死锁。ThreadMXBean 可以检测到 JVM 中的死锁线程，代码如下：
import java.lang.management.ManagementFactory;
import java.lang.management.ThreadInfo;
import java.lang.management.ThreadMXBean;
public class DeadlockDetector {
private static final ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
public static void detectDeadlock() {
long[] deadlockedThreads = threadMXBean.findDeadlockedThreads();
if (deadlockedThreads != null) {
ThreadInfo[] threadInfos = threadMXBean.getThreadInfo(deadlockedThreads);
for (ThreadInfo threadInfo : threadInfos) {
System.out.println("Deadlock detected:");
System.out.println(threadInfo);
}
} else {
System.out.println("No deadlock detected.");
}
}
public static void main(String[] args) {
// Create threads that may lead to deadlock
new Thread(new DeadlockExample()::method1).start();
new Thread(new DeadlockExample()::method2).start();
// Check for deadlock
detectDeadlock();
}
}
通过调用 findDeadlockedThreads 方法，可以检测当前 JVM 中是否有死锁线程，并打印相关信息。
3. Java 中的死锁原因
3.1 资源竞争
死锁的本质是资源竞争。线程 A 持有资源 1，并尝试请求资源 2；与此同时，线程 B 持有资源 2，并尝试请求资源 1。如果双方都不释放各自持有的资源，就会发生死锁。
在电商系统中，常见的场景包括库存锁定和订单生成，两个模块需要同时操作数据库中的库存和订单表。如果不合理设计锁的顺序，就有可能发生死锁。
3.2 锁的嵌套
在多线程环境中，嵌套锁的使用是死锁的常见原因。当一个线程在持有一个锁的情况下，又尝试请求另一个锁时，容易导致死锁。
示例：
public void updateInventoryAndOrder() {
synchronized (inventoryLock) {
synchronized (orderLock) {
// 更新库存和订单
}
}
}
如果两个线程分别在不同的方法中请求相反的锁，就可能出现死锁。
4. 如何避免死锁？
4.1 尽量减少锁的使用
最简单的避免死锁的方法就是减少锁的使用，或者尽量不要对多个资源进行嵌套锁定。
4.2 遵循锁顺序
确保所有线程在获取多个锁时，遵循相同的顺序。通过锁顺序的一致性，可以有效避免死锁。
示例：
public void safeMethod() {
synchronized (lock1) {
synchronized (lock2) {
// 执行操作
}
}
}
在所有需要使用 lock1 和 lock2 的地方，都按照相同的顺序请求锁，从而避免死锁的发生。
4.3 使用 tryLock 方法
Java 中的 ReentrantLock 提供了 tryLock() 方法，可以尝试获取锁，如果获取失败，则不会进入等待状态，从而避免死锁。
示例：
public void safeTryLockMethod() {
if (lock1.tryLock()) {
try {
if (lock2.tryLock()) {
try {
// 执行操作
} finally {
lock2.unlock();
}
}
} finally {
lock1.unlock();
}
}
}
tryLock 提供了更为灵活的锁控制机制，避免线程因获取不到锁而一直等待，进而导致死锁。
5. 电商系统中的死锁示范与避免
在电商交易系统中，库存模块和订单模块的并发操作是高频场景。如果不合理设计锁的获取方式，容易导致死锁。
示例：死锁情境
假设我们有一个电商系统，其中库存和订单分别对应两个锁。
public class EcommerceSystem {
private final Object inventoryLock = new Object();
private final Object orderLock = new Object();
public void updateInventory() {
synchronized (inventoryLock) {
System.out.println("Holding inventory lock...");
try { Thread.sleep(100); } catch (InterruptedException e) {}
synchronized (orderLock) {
System.out.println("Holding order lock...");
}
}
}
public void updateOrder() {
synchronized (orderLock) {
System.out.println("Holding order lock...");
try { Thread.sleep(100); } catch (InterruptedException e) {}
synchronized (inventoryLock) {
System.out.println("Holding inventory lock...");
}
}
}
}
在这种情况下，两个线程同时调用 updateInventory 和 updateOrder 时，可能会出现死锁。
示例：避免死锁
可以通过一致的锁获取顺序来避免死锁：
public class EcommerceSystem {
private final Object inventoryLock = new Object();
private final Object orderLock = new Object();
public void updateInventoryAndOrder() {
synchronized (inventoryLock) {
synchronized (orderLock) {
System.out.println("Holding both inventory and order lock...");
// 执行更新操作
}
}
}
}
在所有操作中，先获取 inventoryLock，再获取 orderLock，确保锁的顺序一致，避免死锁的发生。
6. 总结
Java 死锁是并发编程中的常见问题，尤其是在涉及到多个共享资源时。本文通过电商交易系统的实际场景，介绍了死锁的定义、检测方法以及避免策略。通过合理的锁设计、遵循锁顺序、使用 tryLock 等机制，能够有效地避免 Java 程序中的死锁问题，提高系统的稳定性和并发处理能力。
