java锁的实现原理_深入介绍Java中的锁[原理、锁优化、CAS、AQS]

1、为什么要用锁&＃xff1f;

锁-是为了解决并发操作引起的脏读、数据不一致的问题。

2、锁实现的基本原理

2.1、volatile

Java编程语言允许线程访问共享变量&＃xff0c; 为了确保共享变量能被准确和一致地更新&＃xff0c;线程应该确保通过排他锁单独获得这个变量。Java语言提供了volatile&＃xff0c;在某些情况下比锁要更加方便。

volatile在多处理器开发中保证了共享变量的“ 可见性”。可见性的意思是当一个线程修改一个共享变量时&＃xff0c;另外一个线程能读到这个修改的值。

结论&＃xff1a;如果volatile变量修饰符使用恰当的话&＃xff0c;它比synchronized的使用和执行成本更低&＃xff0c;因为它不会引起线程上下文的切换和调度。

2.2、synchronized

synchronized通过锁机制实现同步。

先来看下利用synchronized实现同步的基础&＃xff1a;Java中的每一个对象都可以作为锁。

具体表现为以下3种形式。

对于普通同步方法&＃xff0c;锁是当前实例对象。

对于静态同步方法&＃xff0c;锁是当前类的Class对象。

对于同步方法块&＃xff0c;锁是Synchonized括号里配置的对象。

当一个线程试图访问同步代码块时&＃xff0c;它首先必须得到锁&＃xff0c;退出或抛出异常时必须释放锁。

2.2.1 synchronized实现原理

synchronized是基于Monitor来实现同步的。

Monitor从两个方面来支持线程之间的同步&＃xff1a;

互斥执行

协作

1、Java 使用对象锁 ( 使用 synchronized 获得对象锁 ) 保证工作在共享的数据集上的线程互斥执行。

2、使用 notify/notifyAll/wait 方法来协同不同线程之间的工作。

3、Class和Object都关联了一个Monitor。

Monitor 的工作机理

线程进入同步方法中。

为了继续执行临界区代码&＃xff0c;线程必须获取 Monitor 锁。如果获取锁成功&＃xff0c;将成为该监视者对象的拥有者。任一时刻内&＃xff0c;监视者对象只属于一个活动线程(The Owner)

拥有监视者对象的线程可以调用 wait() 进入等待集合(Wait Set)&＃xff0c;同时释放监视锁&＃xff0c;进入等待状态。

其他线程调用 notify() / notifyAll() 接口唤醒等待集合中的线程&＃xff0c;这些等待的线程需要重新获取监视锁后才能执行 wait() 之后的代码。

同步方法执行完毕了&＃xff0c;线程退出临界区&＃xff0c;并释放监视锁。

参考文档&＃xff1a;https://www.ibm.com/developerworks/cn/java/j-lo-synchronized

2.2.2 synchronized具体实现

1、同步代码块采用monitorenter、monitorexit指令显式的实现。

2、同步方法则使用ACC_SYNCHRONIZED标记符隐式的实现。

通过实例来看看具体实现&＃xff1a;

public class SynchronizedTest { public synchronized void method1(){ System.out.println("Hello World!"); } public void method2(){ synchronized (this){ System.out.println("Hello World!"); } }}

javap编译后的字节码如下&＃xff1a;

monitorenter

每一个对象都有一个monitor&＃xff0c;一个monitor只能被一个线程拥有。当一个线程执行到monitorenter指令时会尝试获取相应对象的monitor&＃xff0c;获取规则如下&＃xff1a;

如果monitor的进入数为0&＃xff0c;则该线程可以进入monitor&＃xff0c;并将monitor进入数设置为1&＃xff0c;该线程即为monitor的拥有者。

如果当前线程已经拥有该monitor&＃xff0c;只是重新进入&＃xff0c;则进入monitor的进入数加1&＃xff0c;所以synchronized关键字实现的锁是可重入的锁。

如果monitor已被其他线程拥有&＃xff0c;则当前线程进入阻塞状态&＃xff0c;直到monitor的进入数为0&＃xff0c;再重新尝试获取monitor。

monitorexit

只有拥有相应对象的monitor的线程才能执行monitorexit指令。每执行一次该指令monitor进入数减1&＃xff0c;当进入数为0时当前线程释放monitor&＃xff0c;此时其他阻塞的线程将可以尝试获取该monitor。

2.2.3 锁存放的位置

锁标记存放在Java对象头的Mark Word中。

Java对象头长度

32位JVM Mark Word 结构

32位JVM Mark Word 状态变化

64位JVM Mark Word 结构

2.2.3 synchronized的锁优化

JavaSE1.6为了减少获得锁和释放锁带来的性能消耗&＃xff0c;引入了“偏向锁”和“轻量级锁”。

在JavaSE1.6中&＃xff0c;锁一共有4种状态&＃xff0c;级别从低到高依次是&＃xff1a;无锁状态、偏向锁状态、轻量级锁状态和重量级锁状态&＃xff0c;这几个状态会随着竞争情况逐渐升级。

锁可以升级但不能降级&＃xff0c;意味着偏向锁升级成轻量级锁后不能降级成偏向锁。这种锁升级却不能降级的策略&＃xff0c;目的是为了提高获得锁和释放锁的效率。

偏向锁&＃xff1a;

无锁竞争的情况下为了减少锁竞争的资源开销&＃xff0c;引入偏向锁。

轻量级锁&＃xff1a;

轻量级锁所适应的场景是线程交替执行同步块的情况。

锁粗化(Lock Coarsening)&＃xff1a;也就是减少不必要的紧连在一起的unlock&＃xff0c;lock操作&＃xff0c;将多个连续的锁扩展成一个范围更大的锁。

锁消除(Lock Elimination)&＃xff1a;锁削除是指虚拟机即时编译器在运行时&＃xff0c;对一些代码上要求同步&＃xff0c;但是被检测到不可能存在共享数据竞争的锁进行削除。

适应性自旋(Adaptive Spinning)&＃xff1a;自适应意味着自旋的时间不再固定了&＃xff0c;而是由前一次在同一个锁上的自旋时间及锁的拥有者的状态来决定。如果在同一个锁对象上&＃xff0c;自旋等待刚刚成功获得过锁&＃xff0c;并且持有锁的线程正在运行中&＃xff0c;那么虚拟机就会认为这次自旋也很有可能再次成功&＃xff0c;进而它将允许自旋等待持续相对更长的时间&＃xff0c;比如100个循环。另一方面&＃xff0c;如果对于某个锁&＃xff0c;自旋很少成功获得过&＃xff0c;那在以后要获取这个锁时将可能省略掉自旋过程&＃xff0c;以避免浪费处理器资源。

2.2.4 锁的优缺点对比

2.3、CAS

CAS&＃xff0c;在Java并发应用中通常指CompareAndSwap或CompareAndSet&＃xff0c;即比较并交换。

1、CAS是一个原子操作&＃xff0c;它比较一个内存位置的值并且只有相等时修改这个内存位置的值为新的值&＃xff0c;保证了新的值总是基于最新的信息计算的&＃xff0c;如果有其他线程在这期间修改了这个值则CAS失败。CAS返回是否成功或者内存位置原来的值用于判断是否CAS成功。

2、JVM中的CAS操作是利用了处理器提供的CMPXCHG指令实现的。

优点&＃xff1a;

竞争不大的时候系统开销小。

缺点&＃xff1a;

【&＃xff11;】循环时间长开销大。CAS长时间自旋不成功&＃xff0c;给CPU带来很大的性能开销。解决方法&＃xff1a;JVM能支持pause指令&＃xff0c;效率会有一定的提升。

【&＃xff12;】只能保证一个共享变量的原子操作。对多个共享变量操作时&＃xff0c;不能保证原子性。 解决方法&＃xff1a;加锁&＃xff1b;共享变量合并成一个共享变量

【&＃xff13;】ABA的问题。解决方法就是&＃xff1a;增加版本号&＃xff0c;每次使用的时候版本号&＃43;1&＃xff0c;每次变量更新的时候版本号&＃43;1。java提供AtomicStampzedReference来解决ABA问题。

3、Java中的锁实现

3.1、队列同步器(AQS)

队列同步器AbstractQueuedSynchronizer(以下简称同步器)&＃xff0c;是用来构建锁或者其他同步组件的基础框架。

3.1.1、它使用了一个int成员变量表示同步状态。

3.1.2、通过内置的FIFO双向队列来完成获取锁线程的排队工作。

同步器包含两个节点类型的应用&＃xff0c;一个指向头节点&＃xff0c;一个指向尾节点&＃xff0c;未获取到锁的线程会创建节点线程安全(compareAndSetTail)的加入队列尾部。同步队列遵循FIFO&＃xff0c;首节点是获取同步状态成功的节点。

未获取到锁的线程将创建一个节点&＃xff0c;设置到尾节点。如下图所示&＃xff1a;

首节点的线程在释放锁时&＃xff0c;将会唤醒后继节点。而后继节点将会在获取锁成功时将自己设置为首节点。如下图所示&＃xff1a;

3.1.3、独占式/共享式锁获取

独占式&＃xff1a;有且只有一个线程能获取到锁&＃xff0c;如&＃xff1a;ReentrantLock。

共享式&＃xff1a;可以多个线程同时获取到锁&＃xff0c;如&＃xff1a;CountDownLatch

独占式

每个节点自旋观察自己的前一节点是不是Header节点&＃xff0c;如果是&＃xff0c;就去尝试获取锁。

独占式锁获取流程&＃xff1a;

共享式&＃xff1a;

共享式与独占式的区别&＃xff1a;

共享锁获取流程&＃xff1a;

4、锁的使用用例

4.1、ConcurrentHashMap的实现原理及使用

ConcurrentHashMap类图

ConcurrentHashMap数据结构

结论&＃xff1a;ConcurrentHashMap使用的锁分段技术。首先将数据分成一段一段地存储&＃xff0c;然后给每一段数据配一把锁&＃xff0c;当一个线程占用锁访问其中一个段数据的时候&＃xff0c;其他段的数据也能被其他线程访问。