Java并发-如何避免死锁

简介: 一般在Java项目里用到锁的场景不多,有朋友调侃说用到锁的次数还没有面试被问到的次数多,哈哈!

一般在Java项目里用到锁的场景不多,有朋友调侃说用到锁的次数还没有面试被问到的次数多,哈哈!

1、死锁如何产生

说句难听话,锁一般都很少用到,何况死锁呢?想产生死锁还是有点难的,需要满足2个条件:

  • 共享资源同时只能被一个线程使用,如果已经有一个线程占用了资源,其余线程只能等待,直到资源被释放。
  • 死锁情况肯定存在多个资源被多个线程争抢的情况。

比如线程1持有了资源A,然后去等待获取资源B线程2持有了资源B,然后等待获取资源A,这样就会形成死锁

2、如何避免死锁

一般有2种方式避免死锁:

  • 线程一次性获取需要的全部资源。
  • 获取锁时,增加超时动作。如果在一定的时间内获取不到锁,则释放已经获取的锁。

3、代码实践

/**
 * 避免死锁,我觉得有2种方式:
 * 1、线程直接一把头获取所需要的全部锁,不要分步
 * 2、线程获取A之后,再去获取B,超时仍未获取到B,则释放A
 */
public class AvoidDeadLock01 {

    private static Lock lock1 = new ReentrantLock();
    private static Lock lock2 = new ReentrantLock();

    public static void acquireLocks(Lock lock1, Lock lock2) {
        boolean isLock1Acquired = false;
        boolean isLock2Acquired = false;
        while (true) {
            try {
                isLock1Acquired = lock1.tryLock();
                isLock2Acquired = lock2.tryLock();
            } finally {
                if (isLock1Acquired && isLock2Acquired) {
                    return;
                }
                if (isLock1Acquired) {
                    lock1.unlock();
                }
                if (isLock2Acquired) {
                    lock2.unlock();
                }
            }

            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }
    }

    public static void main(String[] args) {
        Thread thread1 = new Thread(() -> {
            acquireLocks(lock1, lock2);
            System.out.println("=====线程1 获取到了2把锁=====");
            lock1.unlock();
            lock2.unlock();
        });
        Thread thread2 = new Thread(() -> {
            acquireLocks(lock1, lock2);
            System.out.println("=====线程2 获取到了2把锁=====");
            lock1.unlock();
            lock2.unlock();
        });
        thread1.start();
        thread2.start();
    }

}
public class AvoidDeadLock02 {

    private static Lock lock1 = new ReentrantLock();
    private static Lock lock2 = new ReentrantLock();

    public static void acquireLocks(Lock lock1, Lock lock2) {
        boolean isLock1Acquired = false;
        boolean isLock2Acquired = false;

        try {
            while (true) {
                isLock1Acquired = lock1.tryLock(200, TimeUnit.MILLISECONDS);
                if (isLock1Acquired) {
                    isLock2Acquired = lock2.tryLock(200, TimeUnit.MILLISECONDS);
                    if (isLock2Acquired) {
                        break;
                    } else {
                        lock1.unlock();
                    }
                }
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            if (!isLock1Acquired || !isLock2Acquired) {
                if (isLock1Acquired) {
                    lock1.unlock();
                }
                if (isLock2Acquired) {
                    lock2.unlock();
                }
            }
        }
    }

    public static void main(String[] args) {
        Thread thread1 = new Thread(() -> {
            acquireLocks(lock1, lock2);
            System.out.println("=====线程1 获取到了2把锁=====");
            lock1.unlock();
            lock2.unlock();
        });
        Thread thread2 = new Thread(() -> {
            acquireLocks(lock1, lock2);
            System.out.println("=====线程2 获取到了2把锁=====");
            lock1.unlock();
            lock2.unlock();
        });
        thread1.start();
        thread2.start();
    }

}

4、出现死锁如何排查

一般出现死锁时,可能会导致CPU、内存等资源消耗过高,导致系统性能下降。也可能导致应用无响应或者假死等等,所以要从多角度进行死锁的排查。

首先是用topdffree等命令查看操作系统的基本情况。然后可以使用jmapjstack等命令查看JVM线程栈和堆内存的情况。一般出现死锁时,会在线程栈的信息里出现deadlock字样。

还可以采用VisualVM、JConsole等工具进行排查。

本篇完结!欢迎点赞 关注 收藏!!!

原文链接http://www.mangod.top/articles/2024/04/02/1712021936664.htmlhttps://mp.weixin.qq.com/s/rmJypq1OgeAPpYzZd_W0Jg

======>>>>>> 关于我 <<<<<<======

相关文章
|
5天前
|
设计模式 安全 Java
Java面试题:设计模式如单例模式、工厂模式、观察者模式等在多线程环境下线程安全问题,Java内存模型定义了线程如何与内存交互,包括原子性、可见性、有序性,并发框架提供了更高层次的并发任务处理能力
Java面试题:设计模式如单例模式、工厂模式、观察者模式等在多线程环境下线程安全问题,Java内存模型定义了线程如何与内存交互,包括原子性、可见性、有序性,并发框架提供了更高层次的并发任务处理能力
17 1
|
5天前
|
安全 算法 Java
Java面试题:如何使用并发集合,例如ConcurrentHashMap?
Java面试题:如何使用并发集合,例如ConcurrentHashMap?
15 1
|
5天前
|
设计模式 存储 安全
Java面试题:设计一个线程安全的单例类并解释其内存占用情况?使用Java多线程工具类实现一个高效的线程池,并解释其背后的原理。结合观察者模式与Java并发框架,设计一个可扩展的事件处理系统
Java面试题:设计一个线程安全的单例类并解释其内存占用情况?使用Java多线程工具类实现一个高效的线程池,并解释其背后的原理。结合观察者模式与Java并发框架,设计一个可扩展的事件处理系统
14 1
|
5天前
|
设计模式 安全 Java
Java面试题:请解释Java中的线程池以及为什么要使用线程池?请解释Java中的内存模型以及如何避免内存泄漏?请解释Java中的并发工具包以及如何实现一个简单的线程安全队列?
Java面试题:请解释Java中的线程池以及为什么要使用线程池?请解释Java中的内存模型以及如何避免内存泄漏?请解释Java中的并发工具包以及如何实现一个简单的线程安全队列?
10 1
|
5天前
|
Java API
Java面试题:解释死锁的概念,给出避免死锁的常见策略。你能给我一个具体的例子吗?
Java面试题:解释死锁的概念,给出避免死锁的常见策略。你能给我一个具体的例子吗?
6 0
|
5天前
|
设计模式 存储 缓存
Java面试题:结合设计模式与并发工具包实现高效缓存;多线程与内存管理优化实践;并发框架与设计模式在复杂系统中的应用
Java面试题:结合设计模式与并发工具包实现高效缓存;多线程与内存管理优化实践;并发框架与设计模式在复杂系统中的应用
8 0
|
5天前
|
设计模式 安全 NoSQL
Java面试题:设计一个线程安全的单例模式,并解释其内存占用和垃圾回收机制;使用生产者消费者模式实现一个并发安全的队列;设计一个支持高并发的分布式锁
Java面试题:设计一个线程安全的单例模式,并解释其内存占用和垃圾回收机制;使用生产者消费者模式实现一个并发安全的队列;设计一个支持高并发的分布式锁
9 0
|
5天前
|
设计模式 缓存 安全
Java面试题:设计模式在并发编程中的创新应用,Java内存管理与多线程工具类的综合应用,Java并发工具包与并发框架的创新应用
Java面试题:设计模式在并发编程中的创新应用,Java内存管理与多线程工具类的综合应用,Java并发工具包与并发框架的创新应用
7 0
|
5天前
|
设计模式 存储 缓存
Java面试题:结合建造者模式与内存优化,设计一个可扩展的高性能对象创建框架?利用多线程工具类与并发框架,实现一个高并发的分布式任务调度系统?设计一个高性能的实时事件通知系统
Java面试题:结合建造者模式与内存优化,设计一个可扩展的高性能对象创建框架?利用多线程工具类与并发框架,实现一个高并发的分布式任务调度系统?设计一个高性能的实时事件通知系统
9 0
|
5天前
|
设计模式 并行计算 安全
Java面试题:如何使用设计模式优化多线程环境下的资源管理?Java内存模型与并发工具类的协同工作,描述ForkJoinPool的工作机制,并解释其在并行计算中的优势。如何根据任务特性调整线程池参数
Java面试题:如何使用设计模式优化多线程环境下的资源管理?Java内存模型与并发工具类的协同工作,描述ForkJoinPool的工作机制,并解释其在并行计算中的优势。如何根据任务特性调整线程池参数
10 0