JUC之锁

这篇具有很好参考价值的文章主要介绍了JUC之锁。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

乐观锁和悲观锁

悲观锁

当一个线程在操作资源的时候,会悲观的认为有其他的线程会来抢占该资源,因此会在操作资源前进行加锁,避免其他线程抢占。
Synchronized关键字和Lock实现类就是悲观锁。
显示的锁定资源后再对资源进行操作。
使用场景:

  • 适合写操作多的场景。先加锁能够保证写操作时数据正确

本质:
加锁去操作同步资源。

乐观锁

当一个线程去操作资源的时候,会乐观的任务其他线程不会来抢占资源,因此不会加锁。
java中通过无锁编程来实现,只是在对数据进行修改的时候,判断其他线程是否对该数据进行修改过

  • 如果没有修改过,该线程直接修改数据。
  • 如果修改过,该线程则根据不同的实现方式执行不同的操作,比如放弃修改,重试抢锁等等。

原子操作类那些底层的是CAS(Compare And swap)算法,也就是乐观锁。
判断规则:

  • 版本号机制Version(每修改一次版本号递增,当前版本号是最大的,可以直接修改。不是最大的,意味着别人修改过了,我的修改要重新处理)
  • 最常采用的是CAS算法(后面会详细讲,这里略)

使用场景:
乐观锁适合读操作多的场景,不加锁读操作性能大幅提升
本质:
无锁去操作同步资源。

乐观锁和悲观锁举例

乐观锁:Synchronized和Lock的实现类
悲观锁:原子操作的类
JUC之锁,JUC,开发语言,juc

Synchronized

阿里加锁规范

高并发时,同步调用时需要考虑加锁性能损耗。能用无锁数据结构就用无锁数据结构。能用块锁,就不要锁方法体。能用对象锁,就不要用类锁。
(尽可能让锁的代码块尽可能小,避免锁造成不必要的性能开销)

Synchronized三种作用方式

作用于实例方法:当前实例加锁,进入实例前要获取当前实例的锁对象。
作用于代码块:对括号里的对象进行加锁。
作用于静态方法(类方法):对当前类加锁,进去同步代码前要获得当前对象的锁。

Synchronized作用于非静态方法和静态方法的区别(重要)

类中Synchronized修饰非静态方法(对象锁)

  • 加的锁为this对象锁。
  • 一个对象只有一把对象锁,因此多个线程执行一个对象的非静态同步方法时,存在竞争关系。先获得对象锁的线程先执行。(不同对象不会有竞争)
  • 不同对象有不同的对象锁,线程如果持有不同对象锁,线程间无竞争的关系。

类中Synchronized修饰静态方法(类锁)

  • 加的锁为类锁。
  • 先获得类锁的线程先执行。多个线程执行同一个类模板的不同对象的静态同步方法的时候,存在竞争关系。先获得类锁的线程先执行。(同一个对象会竞争,不同对象也会竞争)
  • 不同类有不同的类锁,线程如果持有不同的类锁,线程间无竞争关系
  • 一个对象的类锁和对象锁是不同的锁。一个线程持有类锁,一个线程持有对象锁,线程间无竞争关系。

类中无Syncronize修饰的方法(和锁无关)
线程执行该方法不需要获得锁,直接执行就行了。

代码

class Phone //资源类
{
    public static synchronized void sendEmail()
    {
        try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }
        System.out.println("-----sendEmail");
    }

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

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

/**
 * 题目:谈谈你对多线程锁的理解,8锁案例说明
 * 口诀:线程   操作  资源类
 * 8锁案例说明:
 * 1 标准访问有ab两个线程,请问先打印邮件还是短信
 * 2 sendEmail方法中加入暂停3秒钟,请问先打印邮件还是短信
 * 3 添加一个普通的hello方法,请问先打印邮件还是hello
 * 4 有两部手机,请问先打印邮件还是短信
 * 5 有两个静态同步方法,有1部手机,请问先打印邮件还是短信
 * 6 有两个静态同步方法,有2部手机,请问先打印邮件还是短信
 * 7 有1个静态同步方法,有1个普通同步方法,有1部手机,请问先打印邮件还是短信
 * 8 有1个静态同步方法,有1个普通同步方法,有2部手机,请问先打印邮件还是短信
 *
 * 笔记总结:
 * 1-2(对象锁)
 *  *  *  一个对象里面如果有多个synchronized方法,某一个时刻内,只要一个线程去调用其中的一个synchronized方法了,
 *  *  *  其它的线程都只能等待,换句话说,某一个时刻内,只能有唯一的一个线程去访问这些synchronized方法
 *  *  *  锁的是当前对象this,被锁定后,其它的线程都不能进入到当前对象的其它的synchronized方法
 *  3-4
 *  *  加个普通方法后发现和同步锁无关
 *  *  换成两个对象后,不是同一把锁了,情况立刻变化。
 *
 *  5-6(类锁) 都换成静态同步方法后,情况又变化
 *  三种 synchronized 锁的内容有一些差别:
 * 对于普通同步方法,锁的是当前实例对象,通常指this,具体的一部部手机,所有的普通同步方法用的都是同一把锁——>实例对象本身,
 * 对于静态同步方法,锁的是当前类的Class对象,如Phone.class唯一的一个模板
 * 对于同步方法块,锁的是 synchronized 括号内的对象
 *
 * *  7-8
 *  *    当一个线程试图访问同步代码时它首先必须得到锁,正常退出或抛出异常时必须释放锁。
 *  *  *
 *  *  *  所有的普通同步方法用的都是同一把锁——实例对象本身,就是new出来的具体实例对象本身,本类this
 *  *  *  也就是说如果一个实例对象的普通同步方法获取锁后,该实例对象的其他普通同步方法必须等待获取锁的方法释放锁后才能获取锁。
 *  *  *
 *  *  *  所有的静态同步方法用的也是同一把锁——类对象本身,就是我们说过的唯一模板Class
 *  *  *  具体实例对象this和唯一模板Class,这两把锁是两个不同的对象,所以静态同步方法与普通同步方法之间是不会有竞态条件的
 *  *  *  但是一旦一个静态同步方法获取锁后,其他的静态同步方法都必须等待该方法释放锁后才能获取锁。
 */
public class Lock8Demo
{
    public static void main(String[] args)//一切程序的入口
    {
        Phone phone = new Phone();
        Phone phone2 = new Phone();

        new Thread(() -> {
            phone.sendEmail();
        },"a").start();

        //暂停毫秒,保证a线程先启动
        try { TimeUnit.MILLISECONDS.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); }

        new Thread(() -> {
            phone.sendSMS();
//            phone.hello();
//            phone2.sendSMS();
        },"b").start();
    }
}

字节码角度分析Synchronized

查看反汇编:

javap -c *.java// -c对代码进行反汇编。 -v (verbose)输出附加信息行号,本地变量表,反汇编

synchronized同步代码块

  • 实现使用的是monitorenter和monitorexit。monitorenter代表获得锁对象,monitorexit代表释放锁对象。
  • 通常情况下,一个monitorenter对应两个monitorexit,正常情况下,从第一个monitorexit释放锁。异常情况下,从第二个monitorexit释放锁。

synchronized普通同步方法

调用指令时,先检查ACC_SYNCHRONIZED(Access)标志是否被设置了,如果该方法有这个标志,代表是同步方法,访问的时候要获取锁对象。
方法完成时(无论是否正常介数)释放锁。

synchronized静态同步方法

调用指令时,ACC_STATIC,和ACC_SYNCHRONIZED标志。第一个表示是否静态方法,第二个表示是否同步方法。

反编译Synchronized锁是什么

为什么任何一个对象都可以成为锁?
Java虚拟机支持方法级
什么是管程?
管程(Monitor):可以看做是一个功能模块,他将共享变量和对共享变量的操作封装起来。进程可以调用管程实现进程间的并发控制。
同步指令实现?
Java虚拟机支持方法级的同步方法内部指令序列的同步,这两种同步结构都是由管程(Monitor或者称为锁)来实现的。

  • 方法级的同步:通过读取ACC_SYNCHRONIZED判断是否是同步方法,如果是同步方法,执行线程要求必须持有管程(锁)。执行完毕后释放锁。
  • 方法内部指令序列的同步:同步一段指令序列是通过synchronized方法块来表示。java虚拟机指令集中的monitorenter和monitorexit指令实现的。

Monitor的实现 OjectMonitor

每个对象都关联一个ObjectMonitor锁对象。他有一些属性来保证该资源的同步安全。
JUC之锁,JUC,开发语言,juc
ower: 持有该锁的线程
waitset:存放处于wait状态的线程队列
entrylist:存放等待锁的线程队列
recursions(递归):锁的重入次数
count: 记录该线程获取锁的次数。
JUC之锁,JUC,开发语言,juc

公平锁和非公平锁

公平锁(先来先得)

多个线程按照线程请求锁的先后顺序获取锁。默认都是非公平锁,公平锁需要设置。

Lock lock = new ReentrantLock(true);/l/true表示公平锁,先来先得

执行流程:
获取锁的时候,会将线程自己添加到等待队列中并休眠。当线程使用完锁之后,会去唤醒等待队列首部的线程。线程的休眠和恢复需要从用户态转换为内核态,线程切换是比较慢的,所以公平锁的执行较慢。

非公平锁(随机获得锁,默认)

每个线程获取到锁的顺序是随机的,并不会按照先来先得的顺序。所有的线程会竞争获取锁。
执行流程:
当线程申请锁时,会通过CAS尝试获取锁。如果获取成功,就持有锁对象。如果获取失败,就进入等待队列。好处是不用遵循先到先得的原则,避免了线程的休眠和恢复过程,执行更快。

使用场景

默认是非公平锁。能够让程序执行更快(追求效率)。
非公平锁可能造成线程饿死的情况。

可重入锁(递归锁)

定义

可重入锁又叫递归锁。一个线程在外部方法中获取到锁的时候。在进入内部方法需要获取锁的时候,线程会自动获取到该锁。而不会阻塞。

种类

隐式锁(Synchronized关键字修饰的):

线程在外部获取锁之后,内部自动获取到锁。
实现原理
每个锁对象ObjectMonitor都有一个count计数器ower持有该锁对象的线程。
当执行monitorenter的时候:会看count计数器是否为0,如果为0说明该锁对象没有被其他线程占有,将count计数器+1,将ower设置为当前的线程。如果不为0,该线程需要等待。
当执行monitorexit的时候:会将count计数器减一,count为0代表可以释放。将ower清空。

显式锁(Lock实现类)

 lock.lock();//加锁
 lock.unlock();//解锁

加锁和释放锁的次数要一样,不然会导致该线程一直持有锁。其他线程无法获取锁。

死锁

一个线程持有某个锁对象,有需要申请其他的锁对象。其他锁对象被另一个线程占有。在无外力干扰的情况下,一直处于僵持状态。
举例: A线程持有obj1锁对象,申请obj2锁对象。B线程持有obj2锁对象,申请obj1锁对象。A,B线程均被阻塞住,处于僵持状态。

手写一个死锁的例子

final Object obj1 = new Object();
        final Object obj2 = new Object();

        new Thread(() -> {
            synchronized (obj1) {
                System.out.println(Thread.currentThread().getName() + ":" + "拿到了obj1锁对象");
                System.out.println("等待obj2锁对象...");
                synchronized (obj2){
                    System.out.println(Thread.currentThread().getName() + ":" + "拿到了obj2锁对象");
                }
            }
        }, "t1").start();

        new Thread(() -> {
            synchronized (obj2){
                System.out.println(Thread.currentThread().getName() + ":" + "拿到了obj2锁对象");
                System.out.println("等待obj1锁对象...");
                synchronized (obj1){
                    System.out.println(Thread.currentThread().getName() + ":" + "拿到了obj1锁对象");
                }
            }

        }, "t1").start();

运行结果:
JUC之锁,JUC,开发语言,juc

检测死锁

第一种方式命令行jps+jstack

jps查看死锁线程编号

jps -l

JUC之锁,JUC,开发语言,juc
jstack 查看当前时刻的线程快照

jstack 13992

JUC之锁,JUC,开发语言,juc

第二种jconsole图形化界面

JUC之锁,JUC,开发语言,juc
JUC之锁,JUC,开发语言,juc
JUC之锁,JUC,开发语言,juc文章来源地址https://www.toymoban.com/news/detail-803288.html

到了这里,关于JUC之锁的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • JUC的强大辅助类

    juc中提供了常用的辅助类,通过这些辅助类,可以很好的解决线程数量过多时,Lock锁的频繁操作这三种辅助类为: 1.CountDownLatch,减少计数。 2.CyclicBarrier,循环栅栏。 3.Semaphore,信号灯。 减少计数器(CountDownLatch) CountDownLatch类可以设置一个计数器,然后通过countDown方法来进行

    2024年02月05日
    浏览(29)
  • 第九章 JUC并发编程

    http://t.csdn.cn/UgzQi 使用 AQS加 Lock 接口实现简单的不可重入锁 早期程序员会自己通过一种同步器去实现另一种相近的同步器,例如用可重入锁去实现信号量,或反之。这显然不够优雅,于是在 JSR166(java 规范提案)中创建了 AQS,提供了这种通用的同步器机制。 AQS 要实现的功能

    2023年04月08日
    浏览(40)
  • 【JUC基础】14. ThreadLocal

    目录 1、前言 2、什么是ThreadLocal 3、ThreadLocal作用 4、ThradLocal基本使用 4.1、创建和初始化 4.2、存储和获取线程变量 4.3、清理和释放线程变量 4.4、小结 4.5、示例代码 5、ThreadLocal原理 5.1、set() 5.2、get() 5.3、变量清理 5.4、ThreadLocalMap 6、InheritableThreadLocal 一般提到多线程并发总是

    2024年02月07日
    浏览(39)
  • 【JUC并发编程】

    本笔记内容为狂神说JUC并发编程部分 目录 一、什么是JUC 二、线程和进程 1、概述  2、并发、并行 3、线程有几个状态  4、wait/sleep 区别 三、Lock锁(重点)  四、生产者和消费者问题 五、八锁现象 六、集合类不安全  七、Callable ( 简单 ) 八、常用的辅助类(必会) 1、CountDown

    2024年02月09日
    浏览(40)
  • 【JUC进阶】11. BlockingQueue

    目录 1、前言 2、BlockingQueue 2.1、ArrayBlockingQueue 2.1.1、take() 2.1.2、put() 2.2、LinkedBlockingQueue 2.3、PriorityBlockingQueue 2.4、SynchronousQueue 3、简单使用 3.1、创建ArrayBlockingQueue 3.2、Demo 对于并发程序而言,高性能自然是一个我们需要追求的目标,但多线程的开发模式还会引入一个问题,那

    2024年02月16日
    浏览(31)
  • 【juc】读写锁ReentrantReadWriteLock

    一、说明 1.当读操作远远高于写操作时,使用读写锁让读读可以并发,来提高性能 2.类似于数据库中的select … from … lock in share mode 3.提供一个数据容器类,内部分别使用读锁保护数据的read()方法,写锁保护数据的write()方法 二、读读不互斥 2.1 代码示例 2.2 截图示例 三、读写

    2024年02月10日
    浏览(33)
  • 【JUC基础】09. LockSupport

      LockSupport是一个线程阻塞工具,可以在线程任意位置让线程阻塞。线程操作阻塞的方式其实还有Thread.suspend()和Object.wait()。而LockSupport与suspend()相比,弥补了由于resume()方法而导致线程被挂起(类似死锁)的问题,也弥补了wait()需要先获得某个对象锁的问题,也不会抛出Inte

    2024年02月06日
    浏览(57)
  • 多线程---JUC

    JUC是:java.util.concurrent这个包名的缩写。它里面包含了与并发相关,即与多线程相关的很多东西。我们下面就来介绍这些东西。 Callable接口类似与Runnable接口: Runnable接口:描述的任务是不带返回值的。 callable接口:描述的任务是带返回值的,存在的意义就是让我们获取到结果

    2024年02月07日
    浏览(39)
  • 多线程(进阶三:JUC)

    目录 一、Callable接口 1、创建线程的操作 2、编写多线程代码 (1)实现Runnable接口(使用匿名内部类) (2)实现Callable接口(使用匿名内部类) 二、ReentrantLock 1、ReentrantLock和synchronized的区别 2、如何选择使用哪个锁? 三、原子类 四、线程池 五、信号量 Semaphore 代码示例 六、

    2024年02月20日
    浏览(32)
  • JUC之CompletableFuture

    Future接口定义了异步任务执行的一些方法,包括异步任务执行结果,异步任务执行是否中断,异步任务是否完毕等。 CompletableFuture异步线程发生异常,不会影响到主线程,用来记录日志特别方便。 CompletableFuture出现的原因:Future的get方法是阻塞方法,当异步线程计算完成之前

    2024年01月17日
    浏览(35)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包