运维首页 > 开发运维 > synchornized核心原理讲解

synchornized核心原理讲解

2023年 7月 19日 55.1k 0

前言

在此之前先有几个面试题，看大家能答对几题

1.1: 标准访问ab二个线程，是先打印t1还是t2 ？？？

public class SyncUnit {
    
    public synchronized void t1() {
        System.out.println("t1");
    }

    public synchronized void t2() {
        System.out.println("t2");
    }

    public static void main(String[] args) throws Exception{
        SyncUnit syncUnit = new SyncUnit();
        new Thread(() -> {
            syncUnit.t1();
        }).start();

        Thread.sleep(100);

        new Thread(() -> {
           syncUnit.t2();
        }).start();
    }
}

1.2: t1方法暂停3秒钟，是先打印t1还是t2 ？？？

public class SyncUnit {

    public synchronized void t1(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("t1");
    }

    public synchronized void t2() {
        System.out.println("t2");
    }

    public static void main(String[] args) throws Exception{
        SyncUnit syncUnit = new SyncUnit();
        new Thread(() -> {
            syncUnit.t1();
        }).start();

        Thread.sleep(100);

        new Thread(() -> {
           syncUnit.t2();
        }).start();
    }

1.3: 新增一个普通方法hello(),是先打印t1还是hello ????

public class SyncUnit {

    public synchronized void t1(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("t1");
    }

    public synchronized void t2() {
        System.out.println("t2");
    }

    public void hello() {
        System.out.println("hello");
    }

    public static void main(String[] args) throws Exception{
        SyncUnit syncUnit = new SyncUnit();
        new Thread(() -> {
            syncUnit.t1();
        }).start();

        Thread.sleep(100);

        new Thread(() -> {
           syncUnit.hello();
        }).start();
    }
}

1.4: 现在有二个SyncUnit对象，是先打印t1还是t2 ???

public class SyncUnit {

    public synchronized void t1(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("t1");
    }

    public synchronized void t2() {
        System.out.println("t2");
    }

    public static void main(String[] args) throws Exception{
        SyncUnit syncUnit = new SyncUnit();
        SyncUnit syncUnit1 = new SyncUnit();
        new Thread(() -> {
            syncUnit.t1();
        }).start();
        Thread.sleep(100);
        new Thread(() -> {
           syncUnit1.t2();
        }).start();
    }

1.5: 二个静态同步方法，一个SuncUnit对象，是先打印t1还是t2 ????

public class SyncUnit {

    public static synchronized void t1(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("t1");
    }

    public static synchronized void t2() {
        System.out.println("t2");
    }

    public static void main(String[] args) throws Exception{
        SyncUnit syncUnit = new SyncUnit();
        new Thread(() -> {
            syncUnit.t1();
        }).start();
        Thread.sleep(100);
        new Thread(() -> {
           syncUnit.t2();
        }).start();
    }
}

1.6: 二个静态同步方法，二个SyncUnit对象，是先打印t1还是t2

public class SyncUnit {

    public static synchronized void t1(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("t1");
    }

    public static synchronized void t2() {
        System.out.println("t2");
    }

    public static void main(String[] args) throws Exception{
        SyncUnit syncUnit = new SyncUnit();
        SyncUnit syncUnit1 = new SyncUnit();
        new Thread(() -> {
            syncUnit.t1();
        }).start();
        Thread.sleep(100);
        new Thread(() -> {
           syncUnit1.t2();
        }).start();
    }
}

1.7: 一个静态同步方法，普通同步方法，一个SyncUnit对象，是先打印t1还是t2

public class SyncUnit {

    public static synchronized void t1(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("t1");
    }

    public synchronized void t2() {
        System.out.println("t2");
    }

    public static void main(String[] args) throws Exception{
        SyncUnit syncUnit = new SyncUnit();
        new Thread(() -> {
            syncUnit.t1();
        }).start();
        Thread.sleep(100);
        new Thread(() -> {
           syncUnit.t2();
        }).start();
    }
}

1.8 一个静态同步方法，普通同步方法，二个SyncUnit对象，是先打印t1还是t2

public class SyncUnit {

    public static synchronized void t1(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("t1");
    }

    public synchronized void t2() {
        System.out.println("t2");
    }

    public static void main(String[] args) throws Exception{
        SyncUnit syncUnit = new SyncUnit();
        SyncUnit syncUnit1 = new SyncUnit();
        new Thread(() -> {
            syncUnit.t1();
        }).start();
        Thread.sleep(100);
        new Thread(() -> {
           syncUnit1.t2();
        }).start();
    }
}

synchronized用法

synchronized是java提供的一种解决多线程并发安全的一种内置锁，尽管在jdk1.5之前还被大家吐槽性能问题，但是在1.5之后对synchronized不断的优化，在单机程序中，当设计多线程并发问题时，我们完全可以使用synchronized解决

  • 同步实例方法

     public synchronized void method() {
      //方法逻辑
 }

    当synchronized修饰的是一个普通方法的时候，相当于对this对象加锁，一个实例是可以创建多个对象的，所以可以拥有多把锁，就比如下面这个例子，我们创建了二个对象，那就是二把不同的锁，所以在调用t1()的时候，t2()方法由于是不同的锁，所以会直接执行方法

public class SyncUnit {

        public synchronized void t1(){
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("t1");
        }

        public synchronized void t2() {
            System.out.println("t2");
        }

        public static void main(String[] args) throws Exception{
            SyncUnit syncUnit = new SyncUnit();
            SyncUnit syncUnit1 = new SyncUnit();
            new Thread(() -> {
                syncUnit.t1();
            }).start();
            Thread.sleep(100);
            new Thread(() -> {
               syncUnit1.t2();
            }).start();
        }
    }

  • 同步静态方法

     public static synchronized void method() {
     //方法逻辑
 }

    当synchronized修饰的是一个静态方法的时候，相当于对当前实例加锁，一个类只有一个实例，所以无论你创建多少个对象，都只有一把锁，比如下面这个例子，虽然创建了二个不同的对象，但是实际只有一把锁，所以是先打印t1(),然后在打印t2(),因为t2()要等待t1()把锁释放掉之后才能获取到锁


   public class SyncUnit {

            public static synchronized void t1(){
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("t1");
            }

            public static synchronized void t2() {
                System.out.println("t2");
            }

            public static void main(String[] args) throws Exception{
                SyncUnit syncUnit = new SyncUnit();
                SyncUnit syncUnit1 = new SyncUnit();
                new Thread(() -> {
                    syncUnit.t1();
                }).start();
                Thread.sleep(100);
                new Thread(() -> {
                   syncUnit1.t2();
                }).start();
            }
       }

  • 代码块

    
   public Object object = new Object();
   
   public void method() {
      synchronized(object) {
         //方法逻辑
      }
   }

这时候的object是一个对象，就相当于在普通方法上添加synchronized，如果是不同的对象，那么就是不同的锁

      public void method() {
          synchronized(Test.class) {
             //方法逻辑
          }
       }

这时候就相当于在静态方法上添加synchronized，也就是对当前实例加锁，一个类只有一个实例

synchronized核心原理

synchornized是基于JVM中的Monitor锁实现的，Java1.5版本之前的synchornized锁性能较低，但是从1.6版本之后，对synchornized进行了大量的优化，引入了锁粗化，锁消除，偏向锁，轻量级锁，适应性自旋等技术来提升synchornized的性能

  • synchornized修饰的是方法

当synchornized修饰的是方法的时候，当前方法会比普通方法多一个ACC_SYNCHRONIZED的标识符

image.png

当JVM执行程序的时候，会判断这个方法是否有ACC_SYNCHRONIZED这个标识符，如果有，则当前线程优先获取Monitor对象，同一个时刻只能有一个线程获取到，在当前线程释放Monitor对象之前，其它线程无法获取到同一个Monitor对象，从而保证了同一时刻只能有一个线程进入到被synchornized修饰的方法

  • synchornized修饰的是代码块

当synchornized修饰的是代码块的时候，synchornized关键字会被编译成monitorenter和monitorexit，使得同一时刻只能有一个线程进入到同步代码块中，但是这里为什么会有二个monitorexit，是因为程序正常退出的时候需要释放锁，在程序异常的时候也要释放锁，所以会对应二个

image.png

无论synchornized修饰的是方法还是代码块，底层都是通过JVM调用操作系统的Mutes锁实现的，当线程被阻塞时会被挂起，等待CPU重新调度，这会导致线程在操作系统的用户态和内核态之间切换，影响性能

Monitor锁原理

synchornized低成是基于Monitor锁来实现的，而Monitor锁是基于操作系统的Mutex锁实现的，Mutex锁是操作系统级别的重量级锁，所以性能较低

在Java中，创建的任何一个对象在JVM中都会关联一个Monitor对象，所以说任何一个对象都可以成为锁。

在HotSpot JVM中，Monitor是由ObjectMoitor实现的，在ObjectMonitor对象的数据结构中，有几个重要的属性

  • _WaitSet：是一个集合，当线程获到锁之后，但是还没有完成业务逻辑，也还没释放锁，这时候调用了Object类的wait()方法，这时候这个线程就会进入_WaitSet这个集合中等待被唤醒，也就是执行nitify()或者notifyAll()方法唤醒

  • _EntryList：是一个集合，当有多个线程来获取锁，这时候只有一个线程能成功拿到锁，剩下那些没有拿到锁的线程就会进入_EntryList集合中，等待下次抢锁

  • _Owner：当一个线程获取到锁之后，就会将该值设置成当前线程，释放锁之后，这个值就会重新被设置成null

  • _count：当一个线程获取到锁之后，_count的值就会+1，释放锁之后就会-1，只有当减到0之后，才算真正的释放掉锁了，其它线程才能来获取这把锁，synchornized可重入锁也是基于这个值来实现的

所以当多个线程同时访问被synchornized修饰的方法或者代码块时候，synchornized加锁和释放锁的底层实现流程大致为：

  • 1:进入_EntryList集合，当某个线程获取到锁之后，这个线程就会进入_Owner区域，就会将Monitor对象的_owner变量复制为当前线程。并把_count值+1
  • 2:当线程调用wait()方法时，当前线程会释放掉持有的Monitor对象，并把_owner赋值成null，_count的值-1，同时这个线程就会进入_WaitSet集合等到被唤醒
  • 3:如果获取到锁的线程执行完毕，也会释放Monitor锁。，_owner被置为null,_count被置为0

偏向锁

虽然在程序的方法中或代码块中添加了synchornized，但是在大部分的情况下，不会存在多线程竞争这种情况，并且会出现同一个线程多次获取同一把锁的现象，为了提升这种情况下程序的性能，引入了偏向锁

轻量级锁

当多线程竞争锁不激烈时，可以通过CAS机制竞争锁，这就是轻量级锁，引入轻量级锁的目的是在多线程竞争锁不激烈时，避免由于使用操作系统层面的Mutex重量级锁导致性能低下

重量级锁

重量级锁主要是基于操作系统的Mutex锁实现，重量级锁的执行效率较低，处于重量级锁时被阻塞的线程不会消耗CPU资源

锁升级过程

多个线程在争抢synchornized锁时，在某些情况下，会由无锁状态一步步升级为最终的重量级锁，整个升级过程大致包括如下几个步骤

  • 1：线程在竞争synchornized时，JVM首先会检查锁对象的Mark Word中偏向锁的标记位是否为1，锁标记位是否为01，如果二个条件都满足，则当前锁处于偏向锁状态
  • 2：争抢synchornized锁线程检查锁对象的Mark Work中存储的线程ID是否是自己的，如果是自己的线程ID，则表示处于偏向锁状态，当前线程可以直接进入方法或者代码块
  • 3：如果锁对象的Mark Word的线程ID不是自己的线程ID，那么就会通过CAS方式来竞争锁资源，如果获取到锁资源了，就将Mark Word中存储的线程ID修改成自己的线程ID，将偏向锁的标记设置成1，锁标记位置设置成01，当前锁处于偏向锁状态
  • 4：如果当前线程通过CAS没有获取到锁资源，则说明有其它线程也在争抢资源，此时会撤销偏向锁，升级为轻量级锁，并将Mark Word的锁标记为都清空
  • 5：当前线程与其它线程还是会通过CAS方式来竞争资源，如果某个线程成功获取到资源，就会将锁对象的Mark Word中的锁标志位设置成00，此时进入轻量级锁状态
  • 6：竞争失败的线程还是会通过CAS方式来获取锁，但是当CAS达到一定的次数以后，就会升级为重量级锁了
向阳逐梦
开发运维
0 0

相关文章

JavaScript2024新功能：Object.groupBy、正则表达式v标志
PHP trim 函数对多字节字符的使用和限制
新函数 json_validate() 、randomizer 类扩展…20 个PHP 8.3 新特性全面解析
使用HTMX为WordPress增效：如何在不使用复杂框架的情况下增强平台功能
为React 19做准备：WordPress 6.6用户指南
如何删除WordPress中的所有评论

发布评论

向阳逐梦

这个人很懒，什么都没有留下～

文章8411 评论0