【JAVA并发编程专题】死锁的修复和定位

简介: 【JAVA并发编程专题】死锁的修复和定位

正文


一、什么是死锁


死锁(Deadlock):是指两个或两个以上的进程在执行过程中,因争夺资源而造成的一种互相等待的现象,若无外力作用,它们都将无法推进下去。称此时系统处于死锁状态或系统产生了死锁。称这些永远在互相等待的进程为死锁进程。所占用的资源或者需要它们进行某种合作的其它进程就会相继陷入死锁,最终可能导致整个系统处于瘫痪状态。


两个或多个线程之间,由于互相持有对方需要的锁,而永久处于阻塞的状态。


我们来看一个容易造成死锁场景的例子:

@Slf4j
public class DeadLockThread implements Runnable {
    private String lockA;
    private String lockB;
    public DeadLockThread(String threadName, String lockA, String lockB) {
        this.lockA = lockA;
        this.lockB = lockB;
    }
    @Override
    public void run() {
        synchronized (lockA) {
            log.info("{} 获取了{}", Thread.currentThread().getName(), lockA);
            try {
                Thread.sleep(1000L);
                synchronized (lockB) {
                    log.info("{} 获取了{}", Thread.currentThread().getName(), lockB);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
    public static void main(String[] args) {
        String lockA = "lockA";
        String lockB = "lockB";
        // 让t1线程先获取lockA,再获取lockB
        Thread t1 = new Thread(new DeadLockThread("Thread1", lockA, lockB));
        // 让t1线程先获取lockB,再获取lockA
        Thread t2 = new Thread(new DeadLockThread("Thread2", lockB, lockA));
        t1.start();
        t2.start();
    }

当我们启动上述代码后,几乎每次都会进入死锁的状态,即程序一直的得不到结束,但是我们怎么确定程序就是进入了死锁状态呢?


二、死锁问题的定位


2.1 使用jstack工具


jdk中提供了jps和jstack两个工具,先jps查看进程ID,然后jstack查看异常未结束的进程信息;通过信息进一步分析代码问题;如下是对如上例子中的进程pid进行jstack分析的结论:

Found one Java-level deadlock:
=============================
"Thread-1":
  waiting to lock monitor 0x000000001ccb11e8 (object 0x000000076b387cd8, a java.lang.String),
  which is held by "Thread-0"
"Thread-0":
  waiting to lock monitor 0x000000001ccb2f78 (object 0x000000076b387d10, a java.lang.String),
  which is held by "Thread-1"
Java stack information for the threads listed above:
===================================================
"Thread-1":
        at cn.paic.zhangxun.restdemo.deadlock.DeadLockThread.run(DeadLockThread.java:26)
        - waiting to lock <0x000000076b387cd8> (a java.lang.String)
        - locked <0x000000076b387d10> (a java.lang.String)
        at java.lang.Thread.run(Thread.java:745)
"Thread-0":
        at cn.paic.zhangxun.restdemo.deadlock.DeadLockThread.run(DeadLockThread.java:26)
        - waiting to lock <0x000000076b387d10> (a java.lang.String)
        - locked <0x000000076b387cd8> (a java.lang.String)
        at java.lang.Thread.run(Thread.java:745)
Found 1 deadlock.


可以看到,jstack分析结果中明确指出了发生了deadlock现象,并且指出来了thead0和thread1两个线程发生了互相持有和等待对方需要的资源的死锁情况。


2.2 使用标准API扫描


使用Java提供的标准管理API,ThreadMXBean,其有findDeadlockedThreads方法可以找到死锁的地方;

public static void main(String[] args) {
    ThreadMXBean mxBean = ManagementFactory.getThreadMXBean();
    Runnable deadlockCheck = () -> {
      long[] threadIds = mxBean.findDeadlockedThreads();
      if(threadIds != null){
          ThreadInfo[] threadInfos = mxBean.getThreadInfo(threadIds);
          log.warn("发现死锁线程!!!");
          for(ThreadInfo threadInfo:threadInfos){
              log.info("死锁线程ID是{},名称是{}",threadInfo.getThreadId(), threadInfo.getThreadName());
          }
      }else{
          log.info("当前未扫描到死锁线程......");
      }
    };
    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
    // 第一次等2秒,后续每5秒扫描一次
    scheduledExecutorService.scheduleAtFixedRate(deadlockCheck, 2L, 5L, TimeUnit.SECONDS);
}

该方法并没有检测到上述例子中的死锁,具体问题待以后确认。


2.3 代码扫描和代码评审


可以使用一些静态代码扫描工具,比如sonarlint、findbugs等进行代码的静态扫描;


同时加强代码评审,请有并发经验的同事一块看下。


三、如何修复死锁


绝大多数死锁问题都是无法在线解决的,只能找到程序问题之后重新发布解决。


四、如何避免死锁


首先,我们需要知道产生死锁的四个必要条件:


  • 互斥;资源(锁)同一时间只能被一个线程使用;
  • 占有且等待;一个线程占用资源后,等待获取别的资源;
  • 不可抢占;线程已占有的资源自身不释放时别的线程不能抢占;
  • 循环等待;每个线程都占用别的线程需要的资源并等待;
  • 只要打破以上四个条件中的一个,死锁就不会发生了:
  • 尽量避免使用多个锁,并且只有需要时才持有锁,用完立即释放锁;嵌套的synchronized或者lock会非常容易导致问题;
  • 尽量设计好获取锁的顺序,使之不会出现相互持有和等待对方锁的情况;
  • 使用带超时的获取锁的方法;
相关文章
|
5天前
|
存储 缓存 监控
Java面试题:在Java中,对象何时可以被垃圾回收?编程中,如何更好地做好垃圾回收处理?
Java面试题:在Java中,对象何时可以被垃圾回收?编程中,如何更好地做好垃圾回收处理?
16 0
|
5天前
|
Java 测试技术 开发者
Java面试题:解释CountDownLatch, CyclicBarrier和Semaphore在并发编程中的使用
Java面试题:解释CountDownLatch, CyclicBarrier和Semaphore在并发编程中的使用
27 11
|
1天前
|
Java 调度 开发者
Java中的并发编程:从基础到高级
【7月更文挑战第14天】在Java的世界中,并发编程是提升应用性能和响应能力的关键。本文将带领读者从线程的基础概念出发,深入探讨Java内存模型,逐步过渡到高级并发工具类如Executors框架和并发集合,最后通过案例分析展示如何在实际开发中运用这些知识解决并发问题。文章旨在为初学者提供清晰的学习路径,同时为有经验的开发者提供深度参考。
11 4
|
1天前
|
安全 Java 开发者
Java并发编程中的线程安全性与性能优化
在Java编程中,处理并发问题是至关重要的。本文探讨了Java中线程安全性的概念及其在性能优化中的重要性。通过深入分析多线程环境下的共享资源访问问题,结合常见的并发控制手段和性能优化技巧,帮助开发者更好地理解和应对Java程序中的并发挑战。 【7月更文挑战第14天】
|
1天前
|
监控 Java API
Java并发编程之线程池深度解析
【7月更文挑战第14天】在Java并发编程领域,线程池是提升性能、管理资源的关键工具。本文将深入探讨线程池的核心概念、内部工作原理以及如何有效使用线程池来处理并发任务,旨在为读者提供一套完整的线程池使用和优化策略。
|
4天前
|
存储 安全 算法
深入理解Java并发编程:线程安全与性能优化
【5月更文挑战第72天】 在现代软件开发中,尤其是Java应用开发领域,并发编程是一个无法回避的重要话题。随着多核处理器的普及,合理利用并发机制对于提高软件性能、响应速度和资源利用率具有重要意义。本文旨在探讨Java并发编程的核心概念、线程安全的策略以及性能优化技巧,帮助开发者构建高效且可靠的并发应用。通过实例分析和理论阐述,我们将揭示在高并发环境下如何平衡线程安全与系统性能之间的关系,并提出一系列最佳实践方法。
|
1天前
|
Java 开发者
Java并发编程中的锁机制与性能优化
【7月更文挑战第14天】本文深入探讨了Java中锁的概念、种类及其在并发编程中的应用,并分析了不同锁类型对程序性能的影响。通过实例展示了如何合理选择和使用锁来提升应用的性能,同时指出了锁使用过程中可能遇到的问题和调优策略。旨在为Java开发者提供锁机制的深入理解和性能优化的实用建议。
|
5天前
|
Java API
Java面试题:解释死锁的概念,给出避免死锁的常见策略。你能给我一个具体的例子吗?
Java面试题:解释死锁的概念,给出避免死锁的常见策略。你能给我一个具体的例子吗?
6 0
|
5天前
|
Java 数据格式
Java面试题:简述Java Socket编程的基本流程,包括客户端和服务器的创建与通信。
Java面试题:简述Java Socket编程的基本流程,包括客户端和服务器的创建与通信。
11 0
|
4天前
|
Java 调度
Java线程的六种状态
Java线程有六种状态: 初始(NEW)、运行(RUNNABLE)、阻塞(BLOCKED)、等待(WAITING)、超时等待(TIMED_WAITING)、终止(TERMINATED)。
13 1