【JUC】2.多线程锁

心已赠人 2024-04-03 08:17 13阅读 0赞

#### 文章目录 ####

*  1. 乐观锁与悲观锁
 *  2. 从8种锁的案例理解锁
 *  3. 公平锁与非公平锁
 *  4. 可重入锁（递归锁）
 *   *  4.1使用synchronized实现（隐式锁）
     *  4.2 使用ReentrantLock实现（显式锁）
 *  5. 死锁
 *   *  5.1 什么是死锁？？？
     *  5.2 尝试写出一个死锁
     *  5.3 死锁产生的原因
     *  5.4 如何排除死锁

## 1. 乐观锁与悲观锁 ##

**什么是悲观锁呢？**

悲观锁就是认为自己在使用数据的时候一定有别的线程来修改数据，因此在获取数据的数据的时候会先枷锁，确保数据不会被别的线程修改

**根据悲观锁的定义，不难看出，悲观锁适合写操作多的场景，先加锁可以保证操作时数据的正确**

**一个一个人来写，这样就不会写乱了**

**常见的悲观锁有**

*  **synchronized关键字**
 *  **Lock的实现类**

**那么什么是乐观锁呢？**

乐观锁则认为自己在使用数据的时候，不会有别的线程修改数据和资源，所以不会添加锁

在Java中是通过无所编程来实现的，只有在更新数据的时候去判断，之前有没有别的线程更新数据

*  如果这个数据没有被更新，当前线程将自己修改的数据成功写入
 *  如果这个数据已经被其他线程更新，则根据不同的实现方式执行不同的操作，比如放弃修改或者重试抢锁等等

**根据乐观锁的定义。乐观锁适合读操作多的场景，不加锁的特点就是能够使得读操作性能大幅度提升**

简而言之，乐观锁是一个佛系锁。

**乐观锁判断规则**

*  **版本号机制Version**
 *  **常见采用CAS算法，Java原子类中的递增操作就通过CAS自旋实现的**

--------------------

## 2. 从8种锁的案例理解锁 ##

**①标准访问ab两个线程，请问先打印邮件还是短信**

class Phone{
        
        //发邮件
        public synchronized void sendEmail(){
        
            System.out.println("Send Email ~~~~");
        }
        //发短信
        public synchronized void sendSMS(){
        
            System.out.println("Send SMS ~~~");
        }
    }
    
    public class SynchronizedDemo {
        
        public static void main(String[] args) {
        
            Phone phone = new Phone();
    
            new Thread(() -> {
        
                phone.sendEmail();
            }, "a").start();
    
            //休眠200毫秒
            try {
        
                TimeUnit.MICROSECONDS.sleep(200);
            } catch (InterruptedException e) {
        
                throw new RuntimeException(e);
            }
    
            new Thread(() -> {
        
                phone.sendSMS();
            }, "b").start();
    
        }
    }

![在这里插入图片描述][248f0a0aa5594a579a91f211e5d4d14f.png_pic_center]

答案是先打印邮件后打印短信

> 原因是因为两个方法都有synchronized关键字，而两个进程发短信和发邮件使用的都是同一个对象，所以存在竞争关系
> 
> 由于synchronized属于悲观锁，因此当a线程使用这个对象，这个实例对象就会锁住了，其他线程想调用实例的方法需要等待其他线程用完
> 
> **简而言之，同一个实例对象，只要有一个线程调用一个*synchronized*方法，其他线程就必须等待**

**②sendEmail方法加入暂停3秒，打印邮件还是短信**

class Phone{
        
        //发邮件
        public synchronized void sendEmail(){
        
            try {
        
                TimeUnit.MICROSECONDS.sleep(300);
            } catch (InterruptedException e) {
        
                throw new RuntimeException(e);
            }
            System.out.println("Send Email ~~~~");
        }
        //发短信
        public synchronized void sendSMS(){
        
            System.out.println("Send SMS ~~~");
        }
    }
    
    public class SynchronizedDemo {
        
        public static void main(String[] args) {
        
            Phone phone = new Phone();
    
            new Thread(() -> {
        
                phone.sendEmail();
            }, "a").start();
    
            //休眠200毫秒
            try {
        
                TimeUnit.MICROSECONDS.sleep(200);
            } catch (InterruptedException e) {
        
                throw new RuntimeException(e);
            }
    
            new Thread(() -> {
        
                phone.sendSMS();
            }, "b").start();
    
        }
    }

![在这里插入图片描述][9a19e4ad1fc943bdbc23b48dae45fc91.png_pic_center]

> 从这个案例中，更能提现第一个案例的解释了
> 
> 更能提现出锁的是new出来的Phone实例对象

**③添加一个普通方法hello，先打印邮件还是短信**

class Phone{
        //发邮件
        public synchronized void sendEmail(){
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            System.out.println("Send Email ~~~~");
        }
        //发短信
        public synchronized void sendSMS(){
            System.out.println("Send SMS ~~~");
        }
    
        public void hello(){
            System.out.println("hello ~~");
        }
    }
    
    public class SynchronizedDemo {
        public static void main(String[] args) {
            Phone phone = new Phone();
    
            new Thread(() -> {
                phone.sendEmail();
            }, "a").start();
    
            //休眠200毫秒
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
    
            new Thread(() -> {
                phone.hello();
            }, "b").start();
    
        }
    }

![在这里插入图片描述][8686bdf614754e859dd3ff5c40ea931e.png_pic_center]

> 加了普通方法后则与同步锁无关，因此不存在竞争关系

④ 用两台手机，请问先打印邮件还是短信

class Phone{
        
        //发邮件
        public synchronized void sendEmail(){
        
            try {
        
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
        
                throw new RuntimeException(e);
            }
            System.out.println("Send Email ~~~~");
        }
        //发短信
        public synchronized void sendSMS(){
        
            System.out.println("Send SMS ~~~");
        }
    
        public void hello(){
        
            System.out.println("hello ~~");
        }
    }
    
    public class SynchronizedDemo {
        
        public static void main(String[] args) {
        
            Phone phone = new Phone();
            Phone phone1 = new Phone();
    
            new Thread(() -> {
        
                phone.sendEmail();
            }, "a").start();
    
            //休眠200毫秒
            try {
        
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
        
                throw new RuntimeException(e);
            }
    
            new Thread(() -> {
        
                phone1.sendSMS();
            }, "b").start();
    
        }
    }

![在这里插入图片描述][0ea23dcde9884b3ba143da02a3bd4027.png_pic_center]

> 换成两个对象后，因为不是同一把锁了，所以先打印短信后打印邮件
> 
> 同一个对象的时候使用的是该实例做锁

⑤有两个静态同步方法，有一部手机，请问打印的是邮件还是短信

class Phone{
        //发邮件
        public static synchronized void sendEmail(){
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            System.out.println("Send Email ~~~~");
        }
        //发短信
        public static synchronized void sendSMS(){
            System.out.println("Send SMS ~~~");
        }
    
        public void hello(){
            System.out.println("hello ~~");
        }
    }
    
    public class SynchronizedDemo {
        public static void main(String[] args) {
            Phone phone = new Phone();
            Phone phone1 = new Phone();
    
            new Thread(() -> {
                phone.sendEmail();
            }, "a").start();
    
            //休眠200毫秒
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
    
            new Thread(() -> {
                phone.sendSMS();
            }, "b").start();
    
        }
    }

![在这里插入图片描述][b123117e13334724a81f69be72d106c1.png_pic_center]

> 和第二种例子一样，先打印邮件再打印短信
> 
> 在这里是看不出区别，先看看下面的这种情况

⑥有两个静态方法，有两部手机，请问先打印邮件还是短信

class Phone{
        
        //发邮件
        public static synchronized void sendEmail(){
        
            try {
        
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
        
                throw new RuntimeException(e);
            }
            System.out.println("Send Email ~~~~");
        }
        //发短信
        public static synchronized void sendSMS(){
        
            System.out.println("Send SMS ~~~");
        }
    
        public void hello(){
        
            System.out.println("hello ~~");
        }
    }
    
    public class SynchronizedDemo {
        
        public static void main(String[] args) {
        
            Phone phone = new Phone();
            Phone phone1 = new Phone();
    
            new Thread(() -> {
        
                phone.sendEmail();
            }, "a").start();
    
            //休眠200毫秒
            try {
        
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
        
                throw new RuntimeException(e);
            }
    
            new Thread(() -> {
        
                phone1.sendSMS();
            }, "b").start();
    
        }
    }

![在这里插入图片描述][91e29f30d3874ff9a41f56d450412f07.png_pic_center]

> 还是先打印邮件后打印短信，这是为什么呢？
> 
> 这是因为对于普通同步方法，锁的对象是当前实例对象，通常指this，具体的一部手机，所有普通同步方法都是同一把锁，也就是实例对象本身
> 
> 而对于静态同步方法，锁的对象是当前类的class对象，如Phone.class文件，也就是每new一个对象，这多个对象对应的都是同一把锁
> 
> 对于同步方法块，锁的是*synchronized*括号内对象
> 
>     synchronized(o) {
>          
>         
>     }

⑦有一个静态同步方法，有一个普通同步方法，有一部手机，请问先打印邮件还是短信

class Phone{
    
    
        //发邮件
        public static synchronized void sendEmail(){
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            System.out.println("Send Email ~~~~");
        }
        //发短信
        public synchronized void sendSMS(){
            System.out.println("Send SMS ~~~");
        }
    
        public void hello(){
            System.out.println("hello ~~");
        }
    }
    
    public class SynchronizedDemo {
        public static void main(String[] args) {
            Phone phone = new Phone();
            Phone phone1 = new Phone();
    
            new Thread(() -> {
                phone.sendEmail();
            }, "a").start();
    
            //休眠200毫秒
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
    
            new Thread(() -> {
                phone.sendSMS();
            }, "b").start();
    
        }
    }

![在这里插入图片描述][6104397a54204f9abfb55366cf18664b.png_pic_center]

> 前面说到所有普通同步方法用的都是同一把锁——实例对象，就是new出来的实例对象本身。本类this
> 
> 也就是说如果一个实例对象的普通同步方法获取锁后，该实例对象的其他普通同步方法必须等待获取锁的方法释放后才能获取锁
> 
> 所有静态同步方法用的同一把锁——类对象本身，就是我们说过的唯一模板class
> 
> **具体实例对象this和唯一模板class，这两把锁是不同对象，所以静态方法和普通同步方法之间是不会有竞态关系的，但是一旦一个静态同步方法获取锁后，其他静态同步方法就必须等待该方法释放锁后才能获取锁**

⑧有一个静态同步方法，有一个普通同步方法，两台手机，请问先打印邮件还是短信

class Phone{
        
    
    
        //发邮件
        public static synchronized void sendEmail(){
        
            try {
        
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
        
                throw new RuntimeException(e);
            }
            System.out.println("Send Email ~~~~");
        }
        //发短信
        public synchronized void sendSMS(){
        
            System.out.println("Send SMS ~~~");
        }
    
        public void hello(){
        
            System.out.println("hello ~~");
        }
    }
    
    public class SynchronizedDemo {
        
        public static void main(String[] args) {
        
            Phone phone = new Phone();
            Phone phone1 = new Phone();
    
            new Thread(() -> {
        
                phone1.sendEmail();
            }, "a").start();
    
            //休眠200毫秒
            try {
        
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
        
                throw new RuntimeException(e);
            }
    
            new Thread(() -> {
        
                phone.sendSMS();
            }, "b").start();
    
        }
    }

![在这里插入图片描述][6e3cf7fd2ab1463f83c3d837250b6312.png_pic_center]

> 无论是一台手机还是多台手机，静态同步方法和普通同步方法不存在竟态关系

--------------------

## 3. 公平锁与非公平锁 ##

**公平锁：指多个线程按照申请锁的顺序来获取锁，类似排队打饭，先来后到**

**非公平锁：指多个线程获取锁的顺序并不是按照申请锁的顺序，有可能后申请的线程比先申请的线程优先获取锁。在高并发情况下，有可能造成优先级反转和饥饿现象**

而在java.util.concurrent.locks.ReentrantLock的创建可以指定构造函数的boolean类型来得到公平锁或非公平锁。其默认为非公平锁

public ReentrantLock(boolean fair) {
        
        sync = fair ? new FairSync() : new NonfairSync();
    }

**为什么会有公平锁/非公平锁的设计？（为什么默认非公平锁）**

*  恢复挂起线程到真正锁的获取还是有时间差的，从开发人员来看这个时间微乎其微，但是从CPU的角度来看，这个时间差存在的还是比较明显的。所以**非公平锁能更加充分利用CPU的时间片，尽量减少CPU空闲状态的时间**
 *  使用多线程很重要的考量点是线程切换的开销，**当使用非公平锁的时候，当一个线程请求锁获得同步状态然后释放同步状态，所以刚释放锁的线程在此刻再次获得锁状态概率变大，所以减少了线程开销**

**总而言之，非公平锁的效率比公平锁的效率要高**

既然有两种锁，**那么什么时候用公平锁？什么时候用非公平锁呢？**

**前面说到非公平锁的效率比公平锁的效率要高，所以如果是为了更高的吞吐量，很显然非公平锁更加合适，因为节省了很多线程切换时间，吞吐量自然就上去了。否则那就使用公平锁，大家公平使用。**

--------------------

## 4. 可重入锁（递归锁） ##

可重入锁是指同一线程再外层方法获取锁的时候，再次进入该线程内层会自动获取锁（前提，锁的对象是同一个锁），不会因为之前已经获取过还没有释放而阻塞。

如果没有可重入锁，当内外层锁对象是一样的话，准备进入内部的时候需要获取该锁对象，但是该锁对象在进入外层的时候就已经获取了，需要等待自己释放最外层的锁才可以获取内层的锁，这就会出现自我阻塞

**Java中ReentrantLock和synchronized都是可重入锁，可重入锁的一个优点是在一定程度上避免了死锁**

--------------------

### 4.1使用synchronized实现（隐式锁） ###

**隐式锁支持同步块和同步方法**

同步块

public class ReEntryLockDemo {
        
        public static void main(String[] args) {
        
            final Object object = new Object();
    
            new Thread(() -> {
        
                synchronized (object){
        
                    System.out.println(Thread.currentThread().getName() + "\t---外层调用");
                    synchronized (object){
        
                        System.out.println(Thread.currentThread().getName() + "\t---中层调用");
                        synchronized (object){
        
                            System.out.println(Thread.currentThread().getName() + "\t---内层调用");
                        }
                    }
                }
            }).start();
        }
    }

同步方法

public class ReEntryLockDemo {
        
        public static void main(String[] args) {
        
            new ReEntryLockDemo().m1();
        }
    
        public synchronized void m1(){
        
            System.out.println(Thread.currentThread().getName() + "\t---come in m1");
            m2();
            System.out.println(Thread.currentThread().getName() + "\t---end in m1");
        }
    
        public synchronized void m2(){
        
            System.out.println(Thread.currentThread().getName() + "\t---come in m2");
            m3();
        }
    
        public synchronized void m3(){
        
            System.out.println(Thread.currentThread().getName() + "\t---come in m3");
        }
    
    }

--------------------

### 4.2 使用ReentrantLock实现（显式锁） ###

public class ReEntryLockDemo {
        
        public static void main(String[] args) {
        
            ReentrantLock lock = new ReentrantLock();
            lock.lock();
            try {
        
                System.out.println(Thread.currentThread().getName() + "\t---外层调用");
                lock.lock();
                try {
        
                    System.out.println(Thread.currentThread().getName() + "\t---中层调用");
                    lock.lock();
                    try {
        
                        System.out.println(Thread.currentThread().getName() + "\t---内层调用");
                    } finally {
        
                        lock.unlock();
                    }
                } finally {
        
                    lock.unlock();
                }
            } finally {
        
                lock.unlock();
            }
        }
    }

--------------------

## 5. 死锁 ##

### 5.1 什么是死锁？？？ ###

死锁只是两个或两个以上的线程在执行过程中，因争夺资源而造成的一种相互等待的现象；若无外力干涉那么他们无法推进下去，如果系统资源充足，进程资源请求都得到满足，死锁出现的可能性就会很低，否则就会因争夺有限资源而陷入死锁

![在这里插入图片描述][e9d670039a864a2d8877eac4482b0e0f.png_pic_center]

--------------------

### 5.2 尝试写出一个死锁 ###

public class DeadLockDemo {
        
        public static void main(String[] args) {
        
            final Object objectA = new Object();
            final Object objectB = new Object();
    
            new Thread(() -> {
        
                synchronized (objectA){
        
                    System.out.println(Thread.currentThread().getName() + "\t自己持有A锁，希望获得B锁");
                    try {
        
                        TimeUnit.SECONDS.sleep(1);
                    } catch (InterruptedException e) {
        
                        throw new RuntimeException(e);
                    }
                    synchronized (objectB){
        
                        System.out.println(Thread.currentThread().getName() + "\t成功获得B锁");
                    }
                }
            }, "A").start();
    
            new Thread(() -> {
        
                synchronized (objectB){
        
                    System.out.println(Thread.currentThread().getName() + "\t自己持有B锁，希望获得A锁");
                    try {
        
                        TimeUnit.SECONDS.sleep(1);
                    } catch (InterruptedException e) {
        
                        throw new RuntimeException(e);
                    }
                    synchronized (objectA){
        
                        System.out.println(Thread.currentThread().getName() + "\t成功获得A锁");
                    }
                }
            }, "B").start();
        }
    }

--------------------

### 5.3 死锁产生的原因 ###

*  系统资源不足
 *  进程运行推进的顺序不合适
 *  资源分配不当

--------------------

### 5.4 如何排除死锁 ###

有两种方法

使用命令行，我这里使用idea，需要以管理员身份运行idea

然后在命令行输入

jps -l

然后就可以查看到进程编号

![在这里插入图片描述][c28544afc7ac4e6685526a39fe3be1c3.png_pic_center]

再使用另一个命令查看进行信息

jstack 进程号

![在这里插入图片描述][bb9029446399455ba00e07685c6c11d7.png_pic_center]

输出显示发现一个死锁

还有一种方法就是通过图形化

首先win + r输入jconsole

![在这里插入图片描述][f5a963c0ba564340a8fd3e7636edbe47.png_pic_center]

找到进程进行连接

![在这里插入图片描述][d83d35993e344b10848265a7b40bb860.png_pic_center]

点击线程，下面有个检测死锁的按钮

![在这里插入图片描述][d9a734815daa4f1893433d198a3c12a6.png_pic_center]

![在这里插入图片描述][57212ec0ffd84e98a8fac948a485a88f.png_pic_center]

![在这里插入图片描述][1d6f105dda2a48a4bd2a0289d12a8b31.png_pic_center]

--------------------

[248f0a0aa5594a579a91f211e5d4d14f.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/07a7b2dac0644f12b16b69abe4cc205d.png
[9a19e4ad1fc943bdbc23b48dae45fc91.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/ccb9bd9a87d14063a50ac95dd2883fb9.png
[8686bdf614754e859dd3ff5c40ea931e.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/91a41fa4508a4462a92e3722c0fd617a.png
[0ea23dcde9884b3ba143da02a3bd4027.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/a88cf65ee9344da9989a9e9fab1c4070.png
[b123117e13334724a81f69be72d106c1.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/73923449a3884d59aa80f5345f4c0b48.png
[91e29f30d3874ff9a41f56d450412f07.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/f44033ced9e24a6ea06062f4f6ce732a.png
[6104397a54204f9abfb55366cf18664b.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/c74d5827af8340058b2d19f5fe1299a3.png
[6e3cf7fd2ab1463f83c3d837250b6312.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/c1a6f3dbd2c148e2939626c6c39657d9.png
[e9d670039a864a2d8877eac4482b0e0f.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/6d6aa81764484b84877f4b8d12a59f8b.png
[c28544afc7ac4e6685526a39fe3be1c3.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/bb3c6599d8104bfc9515ad7b42b3554e.png
[bb9029446399455ba00e07685c6c11d7.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/6d9938bf08524534a02c254068554b2e.png
[f5a963c0ba564340a8fd3e7636edbe47.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/bc15dd17643c423c8535617855125487.png
[d83d35993e344b10848265a7b40bb860.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/aca8b5e58f2c4609849a212318772ad5.png
[d9a734815daa4f1893433d198a3c12a6.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/f405a1be13da45dbb30cea2fa95db67e.png
[57212ec0ffd84e98a8fac948a485a88f.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/1885ffcfd4c747a09d33e074b975da70.png
[1d6f105dda2a48a4bd2a0289d12a8b31.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/bb319e3e339e4cd9a33058d851fef46e.png