聊聊Java中的那些锁

简介: 说到Java中锁的分类,有很多种。本文就来聊聊公平锁、非公平锁、可重入锁、独占锁、共享锁和自旋锁。

一、公平锁和非公平锁


1、什么是公平锁?什么是非公平锁?


  • 公平锁:是指多个线程按照申请锁的顺序来获取锁,也就是说按秩序排队,先来后到。
  • 非公平锁:是指多个线程获取锁的顺序并不是按照申请锁的顺序来的。就像排队打饭,总有些高年级同学会插队。在高并发情况下,有可能会造成优先级反转或者饥饿现象(优先级反转好理解,就是本来轮到排在队头那个人打饭了,但是突然一人插队跑前面了,这就是优先级反转;如果一直有人插队,那么仅管这个同学已经排在队头了,但是还是一直没吃上饭,这就是饥饿现象)。


2、两者区别:


在并发环境中,每个线程获取锁时都会查看此锁维护的等待队列,如果为空,或者当前线程是等待队列的第一个,就占锁,否则就加入到等待队列中。而非公平锁比较粗鲁,上来就尝试占锁,如果占锁失败,就采用类似公平锁的那种方式。非公平锁性能比较好,吞吐量比较大。ReentrantLock实例化的时候可以传入参数true或者false指定创建公平锁还是非公平锁,true是公平锁,false是非公平锁,不传默认是false。而synchronized也是非公平锁。


欢迎大家关注我的公众号 javawebkf,目前正在慢慢地将简书文章搬到公众号,以后简书和公众号文章将同步更新,且简书上的付费文章在公众号上将免费。


二、可重入锁


1、什么是可重入锁?


可重入锁又叫递归锁。指的是外层函数获得锁之后,它可以进入它所同步着的所有代码,即使内层函数也被锁住,,也无需重新获取锁。

public synchronized void method1(){
        method2();
}
public synchronized void method2(){
}


method1是加了锁的,method2也是加了锁的,然后在method1里面调用method2。当method1获取了锁之后,调用的method2虽然也是加了锁的,但是不用重新获取锁了,这就叫可重入锁。也就说,可以理解为method1和method2获取到的锁可以理解为同一把锁。ReentrantLock和synchronized都是可重入锁。可重入锁最大的作用就是防止死锁。


2、可重入锁demo:


  • 验证synchronized是可重入锁:

public class LockDemo {
    public synchronized void fun1(){
        System.out.println(Thread.currentThread().getId() + "执行fun1方法");
        fun2();
    }
    public synchronized void fun2(){
        System.out.println(Thread.currentThread().getId() + "执行fun2方法");
    }
    public static void main(String[] args){
           LockDemo lockDemo = new LockDemo();
           new Thread( () -> lockDemo.fun1()).start();
    }
}


看这段代码,fun1一个同步方法,在里面输出一句话,然后又调用了同步方法fun2。最后在main方法里面创建一个线程去执行fun1方法。如果synchronized是可重入锁,那么打印这两个输出语句的应该是同一个线程。


image.png


  • 验证ReentrantLock是可重入锁:

public class LockDemo {
    public  void fun1(){
        ReentrantLock lock = new ReentrantLock();
        lock.lock();
        try {
            System.out.println(Thread.currentThread().getName() + ": 执行fun1方法");
            fun2();
        }finally {
            lock.unlock();
        }
    }
    public  void fun2(){
        ReentrantLock lock = new ReentrantLock();
        lock.lock();
        try {
            System.out.println(Thread.currentThread().getName() + ": 执行fun2方法");
        }finally {
            lock.unlock();
        }
    }
    public static void main(String[] args){
           LockDemo lockDemo = new LockDemo();
           new Thread( () -> lockDemo.fun1()).start();
    }
}


这段代码只不过把synchronized换成了lock锁,运行结果是一样的。以上两端代码说明synchronized和ReentrantLock都是可重入锁。


三、自旋锁


前面聊CAS的时候说到了它底层用的就是UnSafe类和自旋锁。这里就详细说一说自旋锁。


1、什么是自旋锁?


我们知道像synchronized和ReentrantLock锁,当这个线程没有获取到锁的时候就是阻塞状态。而自旋锁就是采用循环的方式去尝试获取锁,这样的好处就是减少上下文切换的消耗,但是比较消耗CPU资源。再来看看原子包装类的getAddIncrement方法:

public final int getAndAddInt(Object var1, long var2, int var4) {
        int var5;
        do {
            var5 = this.getIntVolatile(var1, var2);
        } while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));
        return var5;
 }


当while条件不成立时,就会一直执行do语句,所以很消耗CPU。


举个生活中的例子再来说明一下什么是自旋锁:小明同学遇到了个问题,跑到讲台边上去问老师。可是这时候老师在打电话,没办法立即给小明解答。小明就站在边上干等着。这是小明就处于阻塞状态,做不了其他事。而自旋锁就是,小明看到老师现在没时间,就先回到座位上写作业,过一会儿再上去看,老师还没时间,小明又回去做其他事。就这样不断的尝试,知道成功。


2、手写自旋锁:

public class MyLock {
    AtomicReference<Thread> atomicReference = new AtomicReference<>();
    public void myLock() {
        Thread thread = Thread.currentThread();
        System.out.println(thread.getName() + ": come in");
        while (!atomicReference.compareAndSet(null, thread)) {
        }
    }
    public void myUnlock() {
        Thread thread = Thread.currentThread();
        atomicReference.compareAndSet(thread, null);
        System.out.println(thread.getName() + ": come out");
    }
}


分析一下这段代码:这个类有一个成员变量,原子引用类型的Thread,关于原子引用,之前在CAS详解一文中说到过。这个类还有两个方法,一个是myLock加锁方法,一个是myUnlock,释放锁的方法。


  • myLock方法:首先获取到当前线程,然后比较并交换,看看当前线程是不是null,如果是,就设置为当前线程thread,此时操作结果就是true,取反后就是false,就不进入循环。如果当前线程不是null,那么操作结果取反后就是true,那么就会进入循环,知道thread重新变回null为止。
  • myUnlock方法:获取到当前线程,然后将其设置为null,这就相当于释放锁。


用下面的代码测试一下:

public static void main(String[] args) {
        MyLock myLock = new MyLock();
        new Thread(() -> {
            myLock.myLock();
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            myLock.myUnlock();
        },"A").start();
        try {
            TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        new Thread(() -> {
            myLock.myLock();
            myLock.myUnlock();
        },"B").start();
}


A线程进去,发现当前是thread是null,所以就将当前线程指向自己。此时的当前线程就是A,然后小睡5秒。在睡的过程中,B进来了,发现当前线程是A,所以进入while循环,一直进行compareAndSet。5秒中后,A线程释放锁,将当前线程设置为了null,这时B发现当前线程是null了,就将当前线程设置为了B,最后B也释放锁,将当前线程设置为null。如果把线程A的myUnlock方法注释掉,那么线程B将一直在while循环中出不来,造成死循环。


四、独占锁和共享锁


1、什么是独占锁?什么是共享锁?


  • 独占锁:不管是读操作还是写操作,该锁一次只能被一个线程持有。synchronized和ReentrantLock都是独占锁。
  • 共享锁:指该锁可以被多个线程持有。
  • ReentrantReadWriteLock的读锁是共享锁,写锁是独占锁。这样可以保证读操作的并发性。读&读可以共享锁,读&写不能共存,写&写也不能共存。


下面看一段代码:

public class MyCache {
    private volatile Map<String, Object> map = new HashMap<>();
    public void put(String key, Object value){
        System.out.println(Thread.currentThread().getName() + ": 正在写入: "+ value );
        map.put(key, value);
        System.out.println(Thread.currentThread().getName() + ":写入完成");
    }
    public void get(String key){
        System.out.println(Thread.currentThread().getName() + ": 正在读取");
        Object result = map.get(key);
        System.out.println(Thread.currentThread().getName() + ": 读取完成: " + result);
    }
}


这段代码就是模拟一个缓存,用HashMap存数据。现在创建5个线程去写,5个线程去读,看看情况如何。

public static void main(String[] args){
        MyCache myCache = new MyCache();
        for (int i=0; i<5; i++){
            final Integer temp = i;
            new Thread(() -> myCache.put(temp+"", temp),temp +"号线程").start();
        }
        for (int i=0; i<5; i++){
            final Integer temp = i;
            new Thread(() -> myCache.get(temp+""),temp +"号线程").start();
        }
}


看运行结果:


image.png


可以看到,0号线程还没写入完成,2号线程进来了,2号线程还没完成,3号线程又进来了。这就没有保证写操作是独占的,没有保证写操作的原子性。看看使用ReentrantReadWriteLock如何解决:

public class MyCache {
    private volatile Map<String, Object> map = new HashMap<>();
    ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
    public void put(String key, Object value){
        lock.writeLock().lock();
        System.out.println(Thread.currentThread().getName() + ": 正在写入: "+ value );
        map.put(key, value);
        System.out.println(Thread.currentThread().getName() + ":写入完成");
        lock.writeLock().unlock();
    }
    public void get(String key){
        lock.readLock().lock();
        System.out.println(Thread.currentThread().getName() + ": 正在读取");
        Object result = map.get(key);
        System.out.println(Thread.currentThread().getName() + ": 读取完成: " + result);
        lock.readLock().unlock();
    }
}


只需要在写操作那里加写锁,在读操作那里加读锁,这样既可以保证数据的正确性,也提高了并发能力。看运行结果:


image.png


可以看到,写操作的时候,保证了每次写操作的原子性,是独占锁;读的时候可以多个线程同时访问,是共享锁。


总结:


说起锁,好像有很多很多种,其实无外乎synchronized、ReentrantLock、

ReentrantReadWriteLock和 自旋锁。其他的都是从不同角度对这几种锁进行分类而已。


  • synchronized: 是非公平锁、可重入锁、独占锁;
  • ReentrantLock:默认非公平锁,在构造方法中可传入true变成公平锁;是可重入锁,也是独占锁;
  • ReentrantReadWriteLock:读锁是共享锁,写锁是独占锁;
  • 自旋锁:通过CAS实现的一种锁。



相关文章
|
2月前
|
安全 Java 调度
Java编程时多线程操作单核服务器可以不加锁吗?
Java编程时多线程操作单核服务器可以不加锁吗?
44 2
|
12天前
|
缓存 Java
java中的公平锁、非公平锁、可重入锁、递归锁、自旋锁、独占锁和共享锁
本文介绍了几种常见的锁机制,包括公平锁与非公平锁、可重入锁与不可重入锁、自旋锁以及读写锁和互斥锁。公平锁按申请顺序分配锁,而非公平锁允许插队。可重入锁允许线程多次获取同一锁,避免死锁。自旋锁通过循环尝试获取锁,减少上下文切换开销。读写锁区分读锁和写锁,提高并发性能。文章还提供了相关代码示例,帮助理解这些锁的实现和使用场景。
java中的公平锁、非公平锁、可重入锁、递归锁、自旋锁、独占锁和共享锁
|
1月前
|
Java
Java 中锁的主要类型
【10月更文挑战第10天】
|
2月前
|
存储 缓存 安全
【Java面试题汇总】多线程、JUC、锁篇(2023版)
线程和进程的区别、CAS的ABA问题、AQS、哪些地方使用了CAS、怎么保证线程安全、线程同步方式、synchronized的用法及原理、Lock、volatile、线程的六个状态、ThreadLocal、线程通信方式、创建方式、两种创建线程池的方法、线程池设置合适的线程数、线程安全的集合?ConcurrentHashMap、JUC
【Java面试题汇总】多线程、JUC、锁篇(2023版)
|
2月前
|
算法 Java 关系型数据库
Java中到底有哪些锁
【9月更文挑战第24天】在Java中,锁主要分为乐观锁与悲观锁、自旋锁与自适应自旋锁、公平锁与非公平锁、可重入锁以及独享锁与共享锁。乐观锁适用于读多写少场景,通过版本号或CAS算法实现;悲观锁适用于写多读少场景,通过加锁保证数据一致性。自旋锁与自适应自旋锁通过循环等待减少线程挂起和恢复的开销,适用于锁持有时间短的场景。公平锁按请求顺序获取锁,适合等待敏感场景;非公平锁性能更高,适合频繁加解锁场景。可重入锁支持同一线程多次获取,避免死锁;独享锁与共享锁分别用于独占和并发读场景。
|
1月前
|
安全 Java 开发者
java的synchronized有几种加锁方式
Java的 `synchronized`通过上述三种加锁方式,为开发者提供了从粗粒度到细粒度的并发控制能力,满足了不同场景下的线程安全需求。合理选择加锁方式对于提升程序的并发性能和正确性至关重要,开发者应根据实际应用场景的特性和性能要求来决定使用哪种加锁策略。
17 0
|
1月前
|
Java 应用服务中间件 测试技术
Java21虚拟线程:我的锁去哪儿了?
【10月更文挑战第8天】
32 0
|
2月前
|
Java 数据库
JAVA并发编程-一文看懂全部锁机制
曾几何时,面试官问:java都有哪些锁?小白,一脸无辜:用过的有synchronized,其他不清楚。面试官:回去等通知! 今天我们庖丁解牛说说,各种锁有什么区别、什么场景可以用,通俗直白的分析,让小白再也不怕面试官八股文拷打。
|
3月前
|
存储 Java
Java锁是什么?简单了解
在高并发环境下,锁是Java中至关重要的概念。锁或互斥是一种同步机制,用于限制多线程环境下的资源访问,确保排他性和并发控制。例如,超市储物柜仅能存放一个物品,若三人同时使用,则需通过锁机制确保每次只有一个线程访问。Java中可以通过`synchronized`关键字实现加锁,确保关键代码段的原子性,避免数据不一致问题。正确使用锁可有效提升程序的稳定性和安全性。
Java锁是什么?简单了解
|
3月前
|
小程序 Java 开发工具
【Java】@Transactional事务套着ReentrantLock锁,锁竟然失效超卖了
本文通过一个生动的例子,探讨了Java中加锁仍可能出现超卖问题的原因及解决方案。作者“JavaDog程序狗”通过模拟空调租赁场景,详细解析了超卖现象及其背后的多线程并发问题。文章介绍了四种解决超卖的方法:乐观锁、悲观锁、分布式锁以及代码级锁,并重点讨论了ReentrantLock的使用。此外,还分析了事务套锁失效的原因及解决办法,强调了事务边界的重要性。
105 2
【Java】@Transactional事务套着ReentrantLock锁,锁竟然失效超卖了