【JavaEE初阶系列】——synchronized 的特性(互斥和可重入性)

news2024/9/25 19:19:02

目录

💻synchronized 的特性

🖥️互斥及使用示例

🚩锁修饰代码块

🚩锁修饰实例方法/静态方法

🎈锁修饰实例方法

🎈锁修饰静态方法

🚩总结 

🖥️可重入

🚩死锁的现象 

🚩死锁

🎈一个线程一把锁

🎈俩个线程俩把锁

🎈哲学家吃饭(M个线程N个锁)

🚩死锁的成因


从上一篇【JavaEE初阶系列】—— 一万字让你了解线程类方法属性以及线程状态和线程安全问题!-CSDN博客

我们知道线程安全的原因,怎么引起了线程安全问题。接下来我将会讲述如何解决线程安全问题。

上一篇最后讲了,导致count加起来结果不是1w的原因是 count++不是原子性,因为在count++的过程中会经历三个步骤,导致了在多线程的情况下,操作系统,线程的调度顺序是随机的(抢占式执行),所以我们需要加锁。


💻synchronized 的特性


🖥️互斥及使用示例

🚩锁修饰代码块

        synchronized在使用的时候,要搭配一个代码块{} ,进入{ 就会加锁,出了} 就会解锁。在已经加锁的状态下,另一个线程尝试同样加这个锁,就会产生“所冲突/锁竞争",后一个线程就会阻塞等待,一直等到前一个线程解锁为止。

        ()中需要表示一个用来加锁的对象,这个对象是啥不重要,重要的是通过这个对象来区分俩个线程是否在竞争同一个锁。如果俩个线程是在针对同一个对象加锁,就会有锁竞争,如果不是针对同一个对象加锁,就不会有锁竞争,仍然是并发执行。

        你可以将锁想想成一个女生A,一个男生喜欢这个女生A,然后追到手了,就相当于给女生A枷锁了,如果另一个男生B也想追这个女生A,他就必须得阻塞等待,只有等男生A和女生A分手后,他才有机会。但是如果男生B追其他的女生,就不会受到男生A和女生A的影响。

如果按照这样的编程方式,俩个线程是针对同一个对象加锁的,就会有锁竞争。但是线程t2会阻塞等待,等到t1线程结束了之后,t2线程才会开始。

public class Test {
    public static int count=0;
    public static void main(String[] args) throws InterruptedException {
        Object object=new Object();
        Thread t1=new Thread(()->{
            for (int i = 0; i <5000 ; i++) {
                synchronized (object){
                    count++;
                }
            }
        });

        Thread t2=new Thread(()->{
            for (int i = 0; i < 5000; i++) {
                synchronized (object) {
                    count++;
                }
            }
        });
        t1.start();
        t2.start();
        t1.join();
        t2.join();
        System.out.println(count);
    }
}


记住:

  • 锁对象到底用哪个对象,是无所谓的,对象是谁,不重要,重要的是俩线程加锁的对象,是否是同一个对象。
  • 这里的意义/规则,有且只有一个。当俩个线程同时尝试对一个对象加锁,此时就会出现"锁冲突/锁竞争",一旦竞争出现,一个线程能够拿到锁,继续执行代码,一个线程拿不到锁,就只能阻塞等待,等待前一个线程释放锁之后,它才会有机会拿到锁,继续执行。 (并发执行 =》串行执行》

🚩锁修饰实例方法/静态方法

🎈锁修饰实例方法

class Counter{
    public int count;
    synchronized public void  increase(){
        count++;
    }
    public void increase1(){
        synchronized (this){
            count++;
        }
    }
}

以上俩种写法都是可以的,只是上面的写法是下面写法的简化版。此时用的是this锁对象了。


🎈锁修饰静态方法

  synchronized public static void increase(){
        count++;
    }
    public void increase1(){
        synchronized (Counter.class){
            count++;
        }
    }

public static void main(String[] args) throws InterruptedException {
        Object object=new Object();
        Counter counter=new Counter();
        Thread t1=new Thread(()->{
            for (int i = 0; i <5000 ; i++) {
                counter.increase();
            }
        });

        Thread t2=new Thread(()->{
            for (int i = 0; i <5000 ; i++) {
                counter.increase();
            }
        });
        t1.start();
        t2.start();
        t1.join();
        t2.join();
        System.out.println(counter.count);
    }

🚩总结 

锁可以修饰代码块,也可以修饰实例方法和静态方法。其实根本都是对count进行加锁。

代码块中的锁对象可以是任意类型的对象,但多个线程共享的锁对象必须是同一个(因为对同一个变量进行修改)

代码块,实例方法,静态方法的锁是不同的

  • 代码块的锁是自己定义的任意类型的对象。
  • 实例方法就是调用该方法的当前对象,也就是this指向的对象。
  • 静态方法不需要创建对象就可以直接用"类名.方法名()"方式调用。java中静态方法的锁是该方法所在类的class对象,class对象在装载该类的时候自动创建,该对象可以直接用"类名.class"的方式获取。

synchronized 用的锁是存在 Java 对象头里的。

  • 可以粗略理解成, 每个对象在内存中存储的时候, 都存有一块内存表示当前的 "锁定" 状态(类似于厕所的 "有人/无人").
  • 如果当前是 "无人" 状态, 那么就可以使用, 使用时需要设为 "有人" 状态.
  • 如果当前是 "有人" 状态, 那么其他人无法使用, 只能排队.

理解阻塞等待:

针对每一把锁,操作系统内部维护了一个等待队列,当这个锁被某个线程占有的时候,其他线程尝试对其加锁的时候,就加不上了,就会阻塞等待,一直等到之前的线程解锁之后,由操作系统唤醒一个新的线程,再来获取这个锁。

注意:
上一个线程解锁之后, 下一个线程并不是立即就能获取到锁. 而是要靠操作系统来 "唤醒". 这
也就是操作系统线程调度的一部分工作.
假设有 A B C 三个线程, 线程 A 先获取到锁, 然后 B 尝试获取锁, 然后 C 再尝试获取锁, 此时 B 和 C 都在阻塞队列中排队等待. 但是当 A 释放锁之后, 虽然 B 比 C 先来的, 但是 B 不一定就能获取到锁, 而是和 C 重新竞争, 并不遵守先来后到的规则.

🖥️可重入

synchronized 同步块对同一条线程来说是可重入的,不会出现自己把自己锁死的问题;
定义: 一个线程,连续针对一把锁,加锁两次,不会出现死锁 满足这个条件,就是"可重入",不满足就是"不可重入"性。(可重入锁就是可以重复进入的锁,也叫递归锁。前提是同一把锁,如同一个类、同一个实例、同一个代码块)
理解 "把自己锁死"
  • 一个线程没有释放锁, 然后又尝试再次加锁
可重入锁的意义之一在于防止死锁

🚩死锁的现象 

 public static void main(String[] args) {
        Object object=new Object();
        Thread t=new Thread(()->{
            synchronized (object){
                synchronized (object){
                }//(2)
            }//(1)
        });
    }

一个锁对象object,一个线程t,第一次加锁,假设能够加锁成功,此时的object就属于"被锁定"状态,再进行第二次加锁的时候,很明显,object已经是锁定的状态了,第二次加锁操作,原则上来说,是应该要"阻塞等待"的,应该是等待到,锁被释放了之后,才能加锁成功.

但是实际上,一旦第二次加锁的时候阻塞了,就会出现死锁的现象。(线程卡死了)

如果第二次想要加锁成功的话,就需要第一次的加锁释放锁,第一次加锁要想释放锁,就需要执行完完}(1)的位置。要执行到(1) 就需要让第二次加锁能够成功,代码才能成功执行。由于第二次加锁导致了代码阻塞住了,当前没有办法执行到}(1),也就无法释放锁了。

上面的代码很明显是个bug,但是在java中 将synchronized设计成"可重入锁"就可以有效的解决上述死锁的现象。(让锁记录一下,是哪个线程给它锁住的,后续再加锁的时候,如果加锁的线程就是持有锁的线程直接加锁成功了)
public class Test3 {
    public static void main(String[] args) throws InterruptedException {
        Object object=new Object();
        Thread t=new Thread(()->{
            synchronized (object){
                synchronized (object){
                    System.out.println("synchronized设计成可重入锁");
                }
            }
        });
        t.start();
        t.join();
    }
}

但是有一个问题:

上述代码中,synchronized是可重入锁,没有因为第二次加锁而死锁,但是当代码执行到}(2),此时,锁是否应该释放呢? ——不能释放

不管加锁多少层,N层,都是在最外层才能释放锁。

这就引入了计数器,锁对象中,不光要记录谁拿了锁,还要记录,锁被加了几次

  • 没加锁一次,计数器+1
  • 每解锁一次,计数器就-1

出了最后一个大括号,恰好就减成0了,才真正的释放锁。

public class Test3 {
    public static int count=0;
    public static void main(String[] args) throws InterruptedException {
        Object object=new Object();
        Thread t=new Thread(()->{
            synchronized (object){
                count++;
                synchronized (object){
                    System.out.println("synchronized设计成可重入锁");
                    count++;//加锁++
                }
                count--;//解锁--
                synchronized (object){
                    count++;//加锁++
                }
                count--;//解锁--
            }
            count--;
        });
        t.start();
        t.join();
        System.out.println(count);
    }
}

通过加锁+1,解锁-1的操作,我们最后出了大括号之后,恰好就减成0了。


🚩死锁

🎈一个线程一把锁

  • 一个线程,针对一把锁,连续加锁两次,如果是不可重入锁,就会出现死锁现象,被synchronized修饰就是可重入锁。

🎈俩个线程俩把锁

  • 俩个线程,俩把锁。(此时无论是不是可重入锁,都会死锁)就相当于 {车钥匙锁家里了,家钥匙锁车里了}

线程t1获取锁A,t2线程获取锁B

线程t1获取锁B,t2线程获取锁A

public class Test4 {
    private static Object locker1=new Object();
    private static Object locker2=new Object();
    public static void main(String[] args) throws InterruptedException {
        Thread t1=new Thread(()->{
            synchronized (locker1){
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                synchronized (locker2){
                    System.out.println("t1加锁成功");
                }
            }
        });

        Thread t2=new Thread(()->{
            synchronized (locker2){
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                synchronized (locker1){
                    System.out.println("t2加锁成功");
                }
            }
        });
        t1.start();
        t2.start();
    }
}

此时就产生了死锁效果。如果线程1没有sleep的话,是不会出现死锁现象的。这是为什么呢?因为t1.start()的时候,并发执行,首先加locker1的锁,然后没有sleep,此时t2线程就进行了,然后t1线程加锁locker2的基本上同时加锁t2线程locker2.并没有出现t1线程获取locker2锁同时,然后t2线程获取locker1锁.因为中间没有sleep。


🎈哲学家吃饭(M个线程N个锁)

哲学家相当于线程,筷子相当于锁,同一时刻,五个哲学家发现,他们的右手边都没有筷子,与时只能拿起左手的筷子,此时,五个哲学家发现,他们的右手边都没有筷子,只能阻塞等待,等待过程中,,不会放下左手的筷子。这就造成了严重的死锁现象了。


🚩死锁的成因

死锁的成因涉及到四个必要条件。

  • 1.互斥使用(锁的基本特性):当一个线程持有一把锁之后,另一个线程想要拥有这把锁,就需要阻塞等待(适用于 串行执行 二线程一把锁)
  • 2.不可抢占(锁的基本特征):当锁已经被线程1拿到之后,线程2只能等线程1主动释放,不能强行抢占。(男生A和女生A已经在一起了,男生B不能强行让女生A和他在一起,除非等女生A真的不喜欢男生A了,才会和男生B在一起,也适用于 串行执行)
  • 3.请求保持(代码结构):一个线程尝试获取多把锁。(先拿到锁1之后,再尝试获取锁2,获取的时候,锁1不会释放 嵌套执行)
  • 4.循环等待/环路等待(代码结构): 等待的依赖关系,形成环了。

解决死锁,核心就是破坏上述的必要条件,只要破坏一个,死锁就形成不了了。

  • 1和2破坏不了(synchronized自带特性,你无法干预)
  • 对于3来说,调整代码结构,避免编写”锁前套“逻辑
  • 对于4来说,可以预定加锁的顺序,就可以避免循环等待

针对锁进行编号,比如约定,加多把锁的时候,先加编号小的锁,后加编号大的锁。(所有的线程都要遵守这个规则)此时循环等待就破除了,上述系统就不会再出现死锁了。

滑稽1先拿上编号最小的1,然后滑稽2拿上2筷子,滑稽3拿上3筷子,滑稽4拿上4筷子,此时滑稽5拿不了1筷子,只能等待,所以此时滑稽4就可以拿到5筷子,等滑稽4吃完了后,放下,4,5筷子之后,滑稽3就可以拿到4筷子了,以此类推,滑稽1吃完后,滑稽5就可以同时拿到1和5筷子了。

此时就解决了死锁的问题了。


synchronized使用规则上,并不复杂,抓住一个原则:两个线程针对同一个对象加锁,就会产生锁竞争。

其实锁还有个特性是:刷新内存 后面讲到volatile 即可明白。 


今天报考六级了。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1539190.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

AI漫画 角色一致性

具体可以参考油罐我的视频&#xff0c;同名。 1&#xff1a;上传图片 反推提示词 /describe 2&#xff1a;上传图片&#xff0c;获取图片链接&#xff0c;输入提示词 full body shot,Full length,black ninja shoes&#xff0c; Wearing Japanese samurai armor with his zanp…

计算机网络:信道复用技术概念解析

✨✨ 欢迎大家来访Srlua的博文&#xff08;づ&#xffe3;3&#xffe3;&#xff09;づ╭❤&#xff5e;✨✨ &#x1f31f;&#x1f31f; 欢迎各位亲爱的读者&#xff0c;感谢你们抽出宝贵的时间来阅读我的文章。 我是Srlua小谢&#xff0c;在这里我会分享我的知识和经验。&am…

Mongodb入门到入土,安装到实战,外包半年学习的成果

这是我参与「第四届青训营 」笔记创作活动的的第27天&#xff0c;今天主要记录前端进阶必须掌握内容Mongodb数据库,从搭建环境到运行数据库,然后使用MongodB; 一、文章内容 数据库基础知识关系型数据库和非关系型数据库为什么学习Mongodb数据库环境搭建及运行MongodbMongodb命…

linux下用docker部署es和kibana(带ik分词器)(二)

在上一篇文章中讲到&#xff0c;我们利用docker安装了es和kibana&#xff0c;下面我们讲解一下在安装es时把ik分词器这个插件集成进去&#xff0c;首先我们编写一个dockerfile文件&#xff0c;自定义一个es镜像&#xff0c;当然这个镜像肯定集成了ik分词器&#xff0c;具体步骤…

在云上部署我的个人博客!!!

这和上一篇是连起来的&#xff0c;大家先整体看一遍&#xff0c;不要跟&#xff0c;前面有些弯路&#xff01;&#xff01;&#xff01; 【这是按时计费的&#xff0c;欠费不能用&#xff0c;交了好几次哈哈哈哈 】 【我买的域名是&#xff1a;128.1.61.228】 【把域名这个位置…

链动2+1模式深度解析:用户留存与复购数据揭秘

大家好&#xff0c;我是吴军&#xff0c;来自一家专注于软件开发的公司&#xff0c;担任产品经理一职。 今天&#xff0c;我想与大家深入探讨一个话题——链动21模式&#xff0c;以及它是如何有效解决用户留存与复购的难题的。 可能有人会说&#xff0c;链动模式已经存在很久了…

安科瑞AISD300系列三相智能安全配电装置的详细介绍-安科瑞 蒋静

1 概述 AISD300系列三相智能安全配电装置是安科瑞专为低压配电侧开发的一款智能安全配电产品&#xff0c;本产品主要针对低压配电系统人身触电、线路老化、短路、漏电等原因引起电气安全问题而设计。 产品主要应用于学校、加油站、医院、银行、疗养院、康复中心、敬老院、酒店…

现代卷积神经网络

深度卷积神经网络&#xff08;AlexNet&#xff09; 经典机器学习的流水线&#xff1a; ①获取一个有趣的数据集&#xff1b; ②根据光学、几何学&#xff0c;手动对特征数据集进行预处理&#xff1b; ③通过标准的特征提取算法&#xff0c;如SIFT&#xff08;尺度不变特征变…

Typecho 博客文章评论添加显示 UserAgent(UA)的功能

本篇文章实现了为 Typecho 博客文章评论添加显示 UserAgent&#xff08;UA&#xff09;的功能本功能可替代 UserAgent 插件&#xff0c;更美观、简洁且好看 效果显示 大概就是这样了&#xff0c;实际效果请看我的评论&#xff01; 目前可以识别的操作系统以及浏览器 食用方…

AI智能分析网关V4在养老院视频智能监控场景中的应用

随着科技的快速发展&#xff0c;智能监控技术已经广泛应用于各个领域&#xff0c;尤其在养老院这一特定场景中&#xff0c;智能监控方案更是发挥着不可或缺的作用。尤其是伴随着社会老龄化趋势的加剧&#xff0c;养老院的安全管理问题也日益凸显。为了确保老人的生活安全&#…

day16-环形链表

问题描述&#xff1a; 给定一个链表的头节点 head &#xff0c;返回链表开始入环的第一个节点。 如果链表无环&#xff0c;则返回 null。如果链表中有某个节点&#xff0c;可以通过连续跟踪 next 指针再次到达&#xff0c;则链表中存在环。 为了表示给定链表中的环&#xff0…

canvas跟随鼠标移动画带透明度的线

提示&#xff1a;canvas画线 文章目录 前言一、带透明度的线二、试错&#xff0c;只有lineTo的时候画&#xff0c;只有最后地方是透明度的三、试错&#xff0c;只存上一次的点&#xff0c;线会出现断裂的情况总结 前言 一、带透明度的线 test.html <!DOCTYPE html> &l…

@ohos.router (页面路由)实现页面间跳转与数据传递

一、描述 本模块提供通过不同的url访问不同的页面&#xff0c;包括跳转到应用内的指定页面、用应用内的某个页面替换当前页面、返回上一页面或指定的页面等。 二、导入模块 import router from ohos.router 三、router.pushUrl 1、描述 跳转到应用内的指定页面。 router.pu…

OpenAI GPT商店面临质量与合规问题;黄仁勋预测:十年内AI将实时生成游戏画面

&#x1f989; AI新闻 &#x1f680; OpenAI GPT商店面临质量与合规问题 摘要&#xff1a;OpenAI旗下的GPT商店因存在大量涉嫌侵权内容、助长学术不诚实行为及违规内容等问题而引起关注。其中包括未经授权使用迪士尼、漫威角色生成内容的GPT模型&#xff0c;以及声称能绕过剽…

Wireshark TS | DNS 案例分析之外的思考

前言 承接之前一篇《Packet Challenge 之 DNS 案例分析》&#xff0c;在数据包跟踪文件 dnsing.pcapng 中&#xff0c;关于第 4 题&#xff08;What is the largest DNS response time seen in this trace file? &#xff09;的分析过程中曾经碰到一个小问题&#xff0c;主要…

vue-quill-editor和vue-ueditor-wrap富文本编辑器应用

目录 一、vue-quill-editor 1.1、界面展示 1.2、代码介绍 1.2.1、安装 1.2.2、配置 1.2.3、代码应用 1.2.4、提取内容 二、vue-ueditor-wrap 2.1、界面展示 2.2、代码介绍 2.2.1、安装 2.2.2、配置 2.2.3、代码应用 一、vue-quill-editor 1.1、界面展示 文本输出…

极简自建web视频会议,私有云,rtmp/rtsp/webrtc一键参会直播会议互动方案

随着视频互动深入工作日常&#xff0c;很多客户需要自建一个会议&#xff0c;监控的交互平台&#xff0c;目前外面不管是开源还是非开源的平台&#xff0c;都是极为复杂&#xff0c;一般linux安装库关联部署复杂&#xff0c;非技术人员根本没办法使用&#xff0c;不方便集成部署…

C#基于SMTP的邮件发送

准备工作 注册邮箱 首先我们需要注册一个作为发送邮件的邮箱&#xff0c;这一步可以直接进入网易邮箱官网进行注册&#xff0c; 注册地址&#xff1a;https://mail.163.com/ 这里我们可以选择【快速注册】和【普通注册】&#xff0c;如图1-1所示&#xff0c;这里我选择的普…

vue3初步学习

vue3初步学习 vue模版 练习代码如下 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>实验4</ti…

BAAI 北京智源研究院

文章目录 关于 BAAI产品悟道大模型FlagOpen 大模型技术天演 生物智能九鼎 智算平台 关于 BAAI BAAI : Beijing Academy of Artificial Intelligence 北京智源研究院 官网&#xff1a;https://www.baai.ac.cnhf : https://huggingface.co/BAAI百度百科 https://baike.baidu.co…