【多线程与并发】synchronized详解

在 java 语言中,保证线程安全性的主要手段是加锁,而 Java 中的锁主要有两种:synchronized 和 Lock,我们今天重点来看一下 synchronized 的几种用法:

  • 对象锁
    • 方法锁(默认锁对象为this,当前实例对象)
    • 同步代码块锁(自己指定锁对象)
  • 类锁
    • 修饰静态方法
    • 锁对象为Class对象

synchronized的使用

在开始前,让我们先记住使用synchronized是需要注意的几点:

  • 一把锁只能同时被一个线程获取,没有获得锁的线程只能等待;
  • 每个实例都对应有自己的一把锁(this),不同实例之间互不影响(锁对象是Class以及synchronized修饰的是static方法的时候,所有对象公用同一把锁);
  • synchronized修饰的方法,无论方法正常执行完毕还是抛出异常,都会释放锁;

对象锁

方法锁形式:synchronized修饰普通方法,锁对象默认为this

public class ObjectSynchronizedUsage implements Runnable {
   @Override
   public void run() {
     method();
   }
  
   public synchronized void method() {
       System.out.println(Thread.currentThread().getName() + "开始");
     try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "结束");
   }
  
   public static void main(String[] args) {
    ObjectSynchronizedUsage instance = new ObjectSynchronizedUsage();
        Thread t1 = new Thread(instance);
        Thread t2 = new Thread(instance);
        t1.start();
        t2.start();
    }
}

输出结果:

Thread-0开始
Thread-0结束
Thread-1开始
Thread-1结束

代码块形式:自己指定锁对象(this/自定义锁对象)

  • 示例1
public class ObjectSynchronizedUsage implements Runnable {
   @Override
    public void run() {
      //锁为this的同步代码快形式(本质与方法锁一样),两个线程使用同一把锁(this),Thread-1必须等到Thread-0释放掉该锁后,才能执行
       synchronized (this) {
            System.out.println(Thread.currentThread().getName() + "开始");
     try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "结束");
       }
    }
  
    public static void main(String[] args) {
    ObjectSynchronizedUsage instance = new ObjectSynchronizedUsage();
        Thread t1 = new Thread(instance);
        Thread t2 = new Thread(instance);
        t1.start();
        t2.start();
    }
}

输出结果:

Thread-0开始
Thread-0结束
Thread-1开始
Thread-1结束
  • 示例2
public class ObjectSynchronizedUsage implements Runnable {
   // 创建2把锁
    Object block1 = new Object();
    Object block2 = new Object();
   @Override
    public void run() {
       synchronized (block1) {
            System.out.println("block1锁:" + Thread.currentThread().getName() + "开始");
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("block1锁:"+Thread.currentThread().getName() + "结束");
        }

        synchronized (block2) {
            System.out.println("block2锁:" + Thread.currentThread().getName() + "开始");
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("block2锁:"+Thread.currentThread().getName() + "结束");
        }
    }
  
  public static void main(String[] args) {
    ObjectSynchronizedUsage instance = new ObjectSynchronizedUsage();
        Thread t1 = new Thread(instance);
        Thread t2 = new Thread(instance);
        t1.start();
        t2.start();
    }
}

输出结果:

block1锁:Thread-0开始
block1锁:Thread-0结束
block2锁:Thread-0开始  // 可以看到当第一个线程在执行完第一段同步代码块之后,第二个同步代码块可以马上得到执行,因为他们使用的锁不是同一把
block1锁:Thread-1开始
block2锁:Thread-0结束
block1锁:Thread-1结束
block2锁:Thread-1开始
block2锁:Thread-1结束

类锁

synchronized修饰静态方法

示例1:

public class ClassSynchronizedUsage implements Runnable {
   @Override
    public void run() {
        method();
    }
  //synchronized用在普通方法上,默认的锁就是this,当前实例
     public synchronized void method() {
       System.out.println(Thread.currentThread().getName() + "开始");
     try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "结束");
   }
    public static void main(String[] args) {
    ClassSynchronizedUsage instance1 = new ClassSynchronizedUsage();
    ClassSynchronizedUsage instance2 = new ClassSynchronizedUsage();
        // t1和t2对应的this是两个不同的实例,所以代码不会串行
        Thread t1 = new Thread(instance1);
        Thread t2 = new Thread(instance2);
        t1.start();
        t2.start();
    }
}

输出结果:

Thread-0开始
Thread-1开始
Thread-1结束
Thread-0结束
  • 示例2
public class ClassSynchronizedUsage implements Runnable {
  ...
    // 将示例1中的method()方法改为静态方法,synchronized用在静态方法上,默认的锁就是当前所在的Class类,所以无论是哪个线程访问它,需要的锁都只有一把
    public static synchronized void method() {
        System.out.println("我是线程" + Thread.currentThread().getName());
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "结束");
    }
  ...
}

输出结果:

Thread-0开始
Thread-0结束
Thread-1开始
Thread-1结束

synchronized原理

加锁和释放锁的原理

我们从字节码的角度来看下synchronized实现细节。

从上一节我知道synchronized既可以作用于方法,也可以作用于代码块。但在实现上是有区别的。 比如如下代码,使用 synchronized 作用于代码块:

public class SynchronizedTest{
   private int number;
   public void test1(){
        int i = 1;
     synchronized(this){
           number = i + 1;
     }
  }
}

使用javap命令反编译查看字节码:

> javap -verbose SynchronizedTest.class

得到如下信息:

Cgq2xl6X-COAC4hMAAEjW40t64s500.png

可以看到,编译而成的字节码中会包含monitorentermonitorexit这两个字节码指令。

你可能已经发现了,上面的字节码中有1个monitorenter和2个monitorexit,这是因为虚拟机需要保证当异常发生时也能释放锁。因此2个monitorexit一个是代码正常执行结束后释放锁,一个是在代码执行异常时释放锁

在看下synchronized 修饰方法有哪些区别:

public class SynchronizedTest{
   public synchronized void test1(){
        int i = 0;
        i = i + 1;
  }
}

使用javap查看上面方法编译后的字节码如下:

image-20230923213943899.png

从图中可以看出,被synchronized修饰的方法在被编译为字节码后,在方法的flags属性中会被标记为ACC_SYNCHRONIZED标志。当虚拟机访问一个被标记为ACC_SYNCHRONIZED的方法时,会自动在方法的开始和结束(或异常)位置添加monitorentermonitorexit指令。

关于monitorentermonitorexit,可以理解为一把具体的锁。在这个锁中保存着两个比较重要的属性:计数器指针

  • 计数器:记录当前线程一共访问几次这把锁;
  • 指针:指向持有这把锁的线程。

用一张图表示:

Cgq2xl6X-COAEskYAABd1Qkprak432.png

我们来看下monitorentermonitorexit具体是如何工作的:

  • monitorentermonitorexit指令,会让对象在执行时,使其锁计数器加1或者减1。
    [图片上传中...(WechatIMG197.jpg-b015ef-1696404823622-0)]
  • 每一个对象在同一个时间只与一个monitor(锁)关联,而一个monitor在同一个时间只能被一个线程获得。
  • 一个对象在尝试获取与这个对象关联的 monitor锁的所有权的时候,monitorenter指令会发生如下3中情况之一:
    1. monitor计数器为0,表示当前还未被获得,此时这个线程就会立刻获得然后把锁计数器+1,一但+1,其他线程再想获取,就需要等待;
    2. 若这个monitor已经拿到了这个锁的所有权,又重入了这把锁,那锁计数器就会累加,变成2,并且随着重入的次数,会一直累加;
    3. 这把锁已经被其他线程获取了,等待锁释放。
  • monitorexit指令:释放对monitor的所有权。释放过程就是将monitor的计数器-1,如果减完以后,计数器不为0,则表示刚才是重入进来的,当前线程还继续持有这把锁的所有;如果计数器为0,则代表当前线程不再拥有monitor所有权,即锁被释放。

下图表现了ObjectMonitorSynchronizedQueue以及Thread状态之间的关系:

WechatIMG197.jpg

从上图可以看出任意线程对Object的访问,首先要获得Object的monitor,如果获取失败,该线程就会进入同步队列中,该线程状态变为BLOCKED。当monitor持有者释放后,在同步队列中的线程才会有机会重新获取monitor,才能继续执行。

synchronized是可重入锁吗,及其实现原理?

其实在上一节中已经无意透漏出了答案——synchronized是可重入锁。

什么是可重入,可重入锁?

可重入:若一个程序或子程序可以“在任意时刻被中断然后操作系统调度执行另一端代码,这段代码又调用了该子程序不会出错”,则称其为可重入(reentrant或re-entrant)的。即当该子程序正在运行时,执行线程可以再次进入并执行它,仍然获得符合设计时预期的结果。与多线程并发执行的线程安全不同,可重入强调单个线程执行时重新进入同一个子程序仍然是安全的。(来源于维基百科)

可重入锁:又名递归锁,是指在同一个线程在外层方法获取锁的时候,再进入该线程的内层方法会自动获取锁(前提锁对象得是同一个对象或者class),不会因为之前已经获取过还没释放而阻塞。

示例:

public class ChildProgram extends SuperProgram {

    public static void main(String[] args) {
        ChildProgram childProgram = new ChildProgram();
        childProgram.childSomeSthing();
    }

    public synchronized void childSomeSthing (){
        superDoSomeSthing();
        System.out.println("child do Something");
    }

    @Override
    public synchronized void superDoSomeSthing() {
        System.out.println("child do Something");
        super.superDoSomeSthing();
    }
}

public class SuperProgram {

    public synchronized void superDoSomeSthing (){
        System.out.println("super,doing something");
    }
}

执行结果:

child do Something
super,doing something
child do Something

可以看到调用的三个方法均得到了执行。我们知道synchronized修饰普通方法时,使用的是对象锁,也就是ChildProgram对象。三个方法的锁都是ChildProgram对象。我们在子类中执行childSomeSthing方法时,获取了ChildProgram对象锁,然后在childSomeString时调用了重写父类的superDoSomeSthing方法,该方法的锁也是ChildProgram对象锁,然后在其中调用父类的superDoSomeSthing方法,该方法的锁也是ChildProgram对象锁。一个锁多次请求,而且都成功了,所以synchronized是可重入锁。

synchronized可重入锁的实现原理:

结合上一节中加锁和释放锁原理,不难理解:

  • 执行monitorenter获取锁:
    • (monitor计数器=0,可获取锁)
    • 执行childSomeSthing()方法:monitor计数器+1 -> 1(获取到锁)
    • 执行子类中重写的superDoSomeSthing()方法:monitor计数器+1 -> 2
    • 执行父类中superDoSomeSthing()方法:monitor计数器+1 -> 3
  • 执行monitorexit命令:
    • 父类中superDoSomeSthing()方法执行完成:monitor计数器-1 -> 2
    • 子类中重写的superDoSomeSthing()方法执行完成:monitor计数器-1 -> 1
    • childSomeSthing()方法执行完成:monitor计数器-1 -> 0(释放了锁)
    • (monitor计数器=0,锁被释放了)

这就是synchronized的重入性,及在同一锁程中,每个对象拥有一个monitor计数器,当线程获取该对象锁后,monitor计数器就会+1,释放锁后就会将monitor计数器-1,线程不需要再次获取同一把锁。

保证可见性的原理:synchronized的happens-before关系

synchronized的happens-before规则,即监视器锁规则:对同一个监视器的解锁,happens-before于对该监视器的加锁。为进一步了解synchronized的并发语义,通过示例代码分析这条happens-before规则,示例代码如下:

public class MonitorTest{
  private int a = 0;
  public synchronized void writer(){//1
    a++;//2
  }//3
  public synchronized void reader(){//4
    int i = a;//5
  }//6
}

在并发时,第5步操作中读取到的变量a是多少?这就需要通过happens-before规则来进行分析,示例代码的happens-before关系如下图所示:


WechatIMG198.jpg

上图中每一个箭头连接的两个节点就代表之间的happens-before关系:

  1. 黑色的是通过程序顺序规则推到出来。
  2. 红色的为监视器规则推导而出:线程A释放锁happens-before线程B加锁。
  3. 蓝色的则是通过传递性规则进一步推导的happens-before关系。

最终得到结论就是操作2 happens-before 5,通过这个关系我们可以得出以下:

根据happens-before的定义中的一条:如果A happens-before B,则A的执行结果对B可见。那么在上面的代码中,线程A先对共享变量a进行+1,由2 happens-before 5关系可知线程A的执行结果对线程B可见及线程B所读取到的 a的值为1。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 206,214评论 6 481
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 88,307评论 2 382
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 152,543评论 0 341
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 55,221评论 1 279
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 64,224评论 5 371
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,007评论 1 284
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,313评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,956评论 0 259
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,441评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,925评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,018评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,685评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,234评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,240评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,464评论 1 261
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,467评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,762评论 2 345

推荐阅读更多精彩内容