多线程并发--Java线程安全

本文为原创，如需转载请注明来处便可。

目录：Java线程安全

互斥同步

• 定义
• 具体实现
• 字节码指令的具体执行过程
• 字节码指令的2个注意点

• 现代jdk juc包源码解读

  非阻塞同步

• 定义
• 硬件指令集的发展
• cas操做的底层实现
• cas的语义漏洞

• 使用场景分析

  无需同步

• 定义
• 无需同步的2种方式
• ThreadLocal类的源码分析和原理分析
• 消费序列的架构分析

• 使用场景解读

互斥同步

定义

互斥同步（mutual exclusion & synchronization）是常见的一种并发正确性保障手段。同步是指多个线程并发访问共享数据时，保证共享数据在同一时刻只能被一个线程（或者是一些，使用信号量的时候）使用。
互斥是实现同步的一种手段，如临界区，互斥量，信号量都是主要的互斥实现方式。
互斥是因，同步是果。互斥是方法，同步时目的。

具体实现

最基本的互斥实现手段就是synchronized关键字。synchronized关键字通过编译以后，会在同步块的先后分别造成monitorenter和monitorexit字节码指令，这两个字节码都须要一个reference类型的参数来指明锁定和解锁的对象。若是Java程序中的synchronized明确指定了对象参数，那就是这个对象的reference，若是没有明确指定，那就根据synchronized修饰的是实例方法仍是类方法，去取对应的对象实例或class对象来做为锁对象。

字节码指令的具体执行过程

在执行monitorenter指令时，首先要尝试获取对象的锁。若是这个对象没有被锁定，或者当前线程已经拥有了那个对象的锁，把锁的计数器加1，相应的，在执行monitorexit时，将计数器减1，当为0时，锁就被释放。若是获取锁失败，那么当前线程就要阻塞等待，直到对象锁被另外一个线程释放。

字节码指令的2个注意点

1. synchronized同步块对同一个线程来讲是可重入的，不会出现本身把本身锁死的状况。
2. 同步块在已进入线程执行完以前，会阻塞其余的线程进入。

• tip ： Java的线程是映射到操做系统的原生线程上的，若是要阻塞或唤醒一个线程，须要操做系统来完成，就须要从用户态转换为核心态，代价是很大的。因此synchronized是Java语言中的重量级操做。

现代jdk juc包源码解读

TODO:【探究】探究reentrantlock锁（能够和其余类型的锁一块儿总结研究）【源码级别】
TODO:【探索】深刻探索juc包【源码级别】

• ReentrantLock
  • 功能分析：
    • ReentrantLock 和 synchronized 有同样的可重入特性。代码写法上有区别，一个表现为api层面上的互斥锁（lock（），unlock（）方法配合try/finally语句块来完成），一个是原生语法层面上的互斥锁。
    • 相比synchronized，ReentrantLock增长了一些高级特性，如：等待可中断，可实现公平锁，锁能够绑定多个条件。
      • 等待可中断：等待可中断是指当持有锁的线程长期不释放锁的时候，正在等待锁的线程能够放弃等待，改成处理其余事情。
      • 可实现公平锁：公平锁是指多个线程在等待同一个锁时，必须按照锁的申请顺序来一次得到锁。ReentrantLock默认状况下时非公平的，能够经过带布尔型的构造函数要求使用公平锁。
      • 能够绑定多个条件：绑定多个条件是指一个ReentrantLock对象能够绑定多个condition对象。【使用synchronized若是须要绑定多个对象，就要添加锁】
  • 源码解读【TODO:能够单开一个po专门分析juc源码】
  • TIP:虚拟机在将来的性能改进中确定会更加偏向于原生的synchronized，因此仍是提倡synchronized能实现需求的状况下，优先使用synchronized【待验证】。

非阻塞同步

定义（与阻塞同步对比，作了哪些优化）

• 阻塞同步：阻塞同步最主要的问题就是进行线程阻塞和环境带来的性能问题，所以这种同步也称为阻塞同步（blocking synchronization）。从处理问题的方式上看，互斥同步属于一种悲观的并发策略。
• 非阻塞同步：随着硬件指令集的发展，咱们有了另外一个选择：基于冲突检测的乐观并发策略。通俗的讲，就是先进行操做，若是没有其余线程争用贡献数据，那么操做就成功了；若是共享数据有争用，产生了冲突，再采起其余的补偿措施（常见的补偿措施，不断重试，直到成功），这种乐观的并发的许多实现都不须要把线程挂起，所以这种同步成为非阻塞同步（Non-blocking synchronization）。

硬件指令集的发展

乐观并发策略得益于硬件指令集的发展，硬件保证一个从语义上看起来须要屡次操做的行为只须要一条处理器指令集就能够完成，以下：

• 测试并设置（Test-and-Set）
• 获取并增长（Fetch-and-Increment）
• 交换（swap）
• 比较并交换（Compare-and-Swap，简称cas）

• 加载连接/条件存储（LL/SC）

  TIP:再IA64,x86指令集中有cmpxchg指令完成CAS操做。

cas操做的底层实现

• cas指令须要3个操做数，分别是内存位置（再Java中能够简单的理解为变量的内存地址，用V表示），旧的预期值（A），和新值(B)。CAS指令执行时，当且仅当V的值符合旧的预期值A时，处理器用B更新A的值，不然不执行更新，但不管是否更新，返回的都是V的旧值。上述操做是一个原子操做。

  TODO:【探索】从硬件指令集的角度探索cas的原子性。
• CAS在Java中的实现：
  • 在jdk1.5后，Java才开始使用CAS操做，该操做由sun.misc.Unsafe类里面的compareandswapint（）等方法包装提供。虚拟机内部对这些方法多了特殊处理，即时编译以后就是一条平台相关的处理器CAS指令，没有方法调用的过程，或者能够认定是无条件内联进去的。
    ##
    TIP:Unsafe类不是提供给用户调用的类（unsafe.getunsafe()的代码中限制了只有启动类加载器（Bootstrap classloader）加载的class才能访问它【TODO:探索源码】），所以若是不适用反射手段，咱们只能使用java api间接的访问它。如：juc包中的整个原子类，其中的compareandset（）等方法都使用了unsafe的cas操做。
    【TODO:探索源码】。

cas操做的语义漏洞

cas操做不是完美的，存在这样一个逻辑漏洞，简称 “ABA” 问题：

一个线程one从内存位置V中取出A，这时候另外一个线程two也从内存中取出A，而且two进行了一些操做变成了B，而后two又将V位置的数据变成A，这时候线程one进行CAS操做发现内存中仍然是A，而后one操做成功

非阻塞算法使用场景分析

TODO：【探索】cas操做使用场景分析。

无需同步/无同步方案

定义

若是一个方法自己就不涉及共享数据，那就天然无需同步措施来保证正确性。

无需同步的2种方式

• 可重入代码：
  ##
  这种代码也叫作纯代码，能够在代码执行的任什么时候刻中断它，转而去执行另一段代码（包括递归调用它自己），而在控制权返回后，原来的程序不会发生任何错误。
  ##
  全部的可重入代码都是线程安全的，可是并不是全部线程安全的代码都是可重入的。可重入代码都有一些共同的特征，如不依赖堆上共享数据和公共的系统资源，用到的状态量是从参数传入，不调用非可重入的方法等。
  ##
  能够经过简单的原则来判断是否可重入性：若是一个方法，他的返回结果是能够预测的，只要输入了相同的数据，就能够返回相同的结果，那么他就能够知足可重入的要求，固然也就是线程安全的。

• 线程本地存储:
  ##
  java.lang.ThreadLocal类能够实现线程本地存储的功能。每个线程的Thread对象都有一个ThreadLocalMap对象，这个对象存储了以 ThreadLocal.threadLocalHashCode为键，以本地线程变量为值得K-V值对，ThreadLocal对象就是当前线程的ThreadLocalMap访问入口，每个ThreadLocal对象都包含了独一无二的threadLocalHashCode值，就能够找到对应的本地线程变量。
  ##
  大部分使用消费序列的架构模式都会使用线程本地存储。

ThreadLocal类的源码分析和原理分析

TODO:【探究】详细探究ThreadLocal原理及其源码实现，必要的话单开一个po。

消费序列的架构分析

TODO:【延申】尝试探究消息服务队列的线程模型以及消息架构。【参考rocketMQ,KAFKA】

使用场景解读

TODO:【延申】探索本地线程存储的使用场景，并解读。

参考： 《深刻理解Java虚拟机》第二版 《Java并发编程之美》 《rocket mq实战》