Java 可重入锁和不可重入锁的区别
一、可重入锁与不可重入锁的理解
Java多线程有阻塞函数wait()方法和通知函数notify()方法
wait():阻塞当前线程
notify():唤起被wait()阻塞的线程
这两个方法是成对出现和使用的,要执行这两个方法,有一个前提就是,当前线程必须获其对象的monitor(俗称“锁”),否则会抛出IllegalMonitorStateException异常,所以这两个方法必须在同步块代码里面调用。
核心问题场景:当一个线程获得当前实例的锁lock,并且进入了方法A,该线程在方法A没有释放该锁的时候,是否可以再次进入使用该锁的方法B?
不可重入锁:在方法A释放锁之前,不可以再次进入方法B
可重入锁:在方法A释放该锁之前,可以再次进入方法B
1)不可重入锁:
当线程在访问A方法的时候,获取的A方法的锁,在A方法锁释放之前不能够访问其他方法(如方法B)的锁。
不可重入锁模型:{}{}{}{}{}都是独立的访问每一个方法,加锁 - 释放;加锁 - 释放。。。
2)可重入锁:
当线程在访问A方法的时候,获取A方法的锁,然后访问B方法获取B方法的锁,并计数加1,以此类推可以访问完了以后依次解锁。
可重入锁模型:{{{{}}}} 每次都可访问另一个方法,且加锁计数器加1,完全释放锁为计数器等于0
二、可重入锁
可重入锁,是指同一个线程可以重入上锁的代码段,不同的线程进入则需要进行阻塞等待。
Java的可重入锁有:reentrantLock(显式的可重入锁)、synchronized(隐式的可重入锁)
可重入锁诞生的目的就是防止死锁,导致同一个线程不可重入上锁代码段,目的就是让同一个线程可以重新进入上锁代码段。
设计可重入锁的示例代码
public class MyReentrantLock { boolean isLocked = false; // 默认没有上锁 Thread lockedBy = null; // 记录阻塞线程 int lockedCount = 0; // 上锁次数计数 /** * 上锁逻辑 */ public synchronized void lock() throws InterruptedException { Thread thread = Thread.currentThread(); // 上锁了 并且 如果是同一个线程则放行,否则其它线程需要进入where循环进行等待 while (isLocked && lockedBy != thread) { wait(); } isLocked = true; // 第一次进入就进行上锁 lockedCount++; // 上锁次数计数 lockedBy = thread; // 当前阻塞的线程 } /** * 释放锁逻辑 */ public synchronized void unlock() { if (Thread.currentThread() == this.lockedBy) { lockedCount--; // 将上锁次数减一 if (lockedCount == 0) {// 当计数为0,说明所有线程都释放了锁 isLocked = false; // 真正的将释放了所有锁 notify(); } } } }
1、可重入锁 synchronized
package com.test.reen; // 演示可重入锁是什么意思,可重入,就是可以重复获取相同的锁,synchronized和ReentrantLock都是可重入的 // 可重入降低了编程复杂性 public class WhatReentrant { public static void main(String[] args) { new Thread(new Runnable() { @Override public void run() { synchronized (this) { System.out.println("第1次获取锁,这个锁是:" + this); int index = 1; while (true) { synchronized (this) { System.out.println("第" + (++index) + "次获取锁,这个锁是:" + this); } if (index == 10) { break; } } } } }).start(); } }
2、可重入锁 reentrantLock
package com.test.reen; import java.util.Random; import java.util.concurrent.locks.ReentrantLock; // 演示可重入锁是什么意思 public class WhatReentrant2 { public static void main(String[] args) { ReentrantLock lock = new ReentrantLock(); new Thread(new Runnable() { @Override public void run() { try { lock.lock(); System.out.println("第1次获取锁,这个锁是:" + lock); int index = 1; while (true) { try { lock.lock(); System.out.println("第" + (++index) + "次获取锁,这个锁是:" + lock); try { Thread.sleep(new Random().nextInt(200)); } catch (InterruptedException e) { e.printStackTrace(); } if (index == 10) { break; } } finally { lock.unlock(); } } } finally { lock.unlock(); } } }).start(); } }
可以发现,上面的两个可重入锁 synchronized 和 reentrantLock,都没发生死锁,可以多次获取相同的锁
注意点:ReentrantLock 和 synchronized 还不一样,ReentrantLock需要手动释放锁,所以使用 ReentrantLock的时候一定要手动释放锁,并且加锁次数和释放次数要一样,最好在 finally 中jin'x进行锁释放
三、不可重入锁
不可重入锁,是指同一个线程不可以重入上锁后的代码段
如下代码示例,是一个不可重入锁的逻辑过程。
代码示例:
public class Count{ MyLock lock = new MyLock(); public static void main(String[] args) throws InterruptedException { new Count().doSomeThing(); // 示例的main方法 } public void doSomeThing() throws InterruptedException { lock.lock(); // 第一次上锁 System.out.println("执行doJob方法前"); doJob(); // 方法内会再次上锁 lock.unlock(); // 释放第一次上的锁 } public void doJob() throws InterruptedException { lock.lock(); System.out.println("执行doJob方法过程中"); lock.unlock(); } } /** * 自定义锁 */ class MyLock{ private boolean isLocked = false; public synchronized void lock() throws InterruptedException{ while(isLocked){ wait(); } isLocked = true; // 线程第一次进入后就会将器设置为true,第二次进入是就会由于where true进入死循环 } public synchronized void unlock(){ isLocked = false; // 将这个值设置为false目的是释放锁 notify(); // 结束阻塞 } }
从上面代码,您会发现执行main方法控制台会打印 "执行doJob方法前",然后就会一直线程阻塞,不会打印 "执行doJob方法过程中",原因在于第一次上锁后,由于没有释放锁,因此执行第一次lock后isLocked = true,这个时候调用doJob()内部又一次调用了lock(),由于上个线程将isLocked = true,导致再次进入的时候就进入死循环。从而导致线程无法执行System.out.println("执行doJob方法过程中");这行代码,因此控制台只能打印 "执行doJob方法前"。这种现象就造成了不可重入锁
参考推荐:
版权所有: 本文系米扑博客原创、转载、摘录,或修订后发表,最后更新于 2021-03-13 05:12:35
侵权处理: 本个人博客,不盈利,若侵犯了您的作品权,请联系博主删除,莫恶意,索钱财,感谢!