JAVA多线程高并发

• JAVA内存模型：目标是定义程序中各个变量的访问规则。
  • 所有的变量都存储在主内存中
  • 每条线程都有自己的工作内存，线程的工总内存中保存了该线程适用到的变量的主内存的副本拷贝，线程对变量的所有操作都必须在工作内存中进行，而不能直接读写主内存中的变量。
  • 线程之间无法直接访问对方的工作内存中的变量，线程之间的变量的传递均需要通过主内存来完成。
  • 内存之间的交互操作：
    
    • Lock（锁定）：作用于主内存中的变量，把一个变量标识为一条线程独占的状态。
    • Read（读取）：作用于主内存中的变量，把一个变量的值从主内存传输到线程的工作内存中。
    • Load（加载）：作用于工作内存中的变量，把read操作从主内存中得到的变量的值放入到工作内存中的变量。
    • Use（使用）：作用与工作内存中的变量，把工作内存中一个变量的值传递给执行引擎。
    • Assign（赋值）：作用于工作内存中的变量，把一个从执行引擎接收到的值赋给工作内存中的变量。
    • Store（存储）：作用于工作内存中的变量，把工作内存中的一个变量的值传送到主内存中。
    • Write（写入）：作用与主内存中的变量，把store操作从工作内存中得到变量的值放入到主内存的变量中。
    • Unlock（解锁）：作用于主内存中的变量，把一个处于锁定状态的变量释放出来，之后可被其他线程锁定。
  • 规则：
    • 不允许read和load、store和write操作之一单独出现。
    • 不允许一个线程丢弃最近的assign操作，变量在工作内存中改变了之后必须要把该变化同步会主内存中。
    • 不允许一个线程没有发生过任何assign操作把数据从线程的工程内存同步会主内存中。
    • 一个新的变量只能在主内存中诞生。
    • 一个变量在同一时刻只允许一条线程对其进行lock操作，但可以被同一条线程重复执行多次。
    • 如果对一个变量执行lock操作，将会清空工作内存中此变量的值，在执行引擎使用这个变量前，需要重新执行read、load操作。
    • 如果一个变量事先没有被lock操作锁定，则不允许对他执行unlock操作。
    • 对一个变量执行unlock操作前，必须先把该变量同步回主内存中。
• voilatile型变量
  • 保证此变量对所有线程的可见性。每条线程使用此类型变量前都需要先刷新，执行引擎看不到不一致的情况。
  • 运算结果并不依赖变量的当前值、或者确保只有单一的线程修改变量的值。
  • 变量不需要与其他的状态变量共同参与不变约束。
    • 禁止指令重排序优化。普通的变量仅保证在方法执行过程中所有依赖赋值结果的方法都能获取到正确的结果。而不能保证赋值操作的顺序与程序代码中的顺序一致。
    • load必须与use同时出现，assign和store必须同时出现。
• 原子性、可见性与有序性
  • 原子性：基本数据类型的访问读写是具备原子性的，synchronized块之间的操作也具备原子性。
  • 可见性：指当一个线程修改了共享变量的值，其他线程能够立即得知这个修改。synchronized和final可以保证可见性。final修饰的字段在构造器中一旦被初始化，并且构造器没有把this的引用传递出去，那么在其他线程中就能看到final字段的值。
  • 有序性：voliatile本身包含了禁止指令重新序的语义，而synchronized则由先行发生原则获得的，这个规则决定了持有同一个所得两个同步块只能串行地进入。
• 先行发生原则
  • java内存模型中定义的两项操作之间的偏序关系，如果操作A先于操作B发生，其实就是说在发生操作B之前，操作A产生的影响能被操作B观察到。
  • 程序次序规则：在一个线程内，按照代码控制流顺序，在前面的操作先行发生于后面的操作。
  • 管程锁定规则：一个unlock操作先行发生于后面对同一个锁的lock操作。
  • volatile变量规则：对一个volatile变量的写操作先行发生于后面对这个变量的读操作。
  • 线程启动规则：Thread对象的start()方法先行发生于对此线程的每个操作。
  • 线程终止规则：线程中的所有操作都先行发生于对此线程的终止检测。
  • 线程中断规则：对线程的interrupt()方法的调用先行发生于被中断线程的代码检测中断事件的发生。
  • 对象终结规则：一个对象的初始化完成先行发生于他的finalize()方法的开始。
  • 传递性：如果操作A先行发生于操作B，操作B现象发生于操作C，那个接可以得出操作A先行发生于操作C的结论。
  • 时间上的先后顺序与先行发生原则之间基本上没有太大的关系。
• 线程调度
  • 线程调度是指系统为线程分配处理器使用权的过程：协同式、抢占式。
  • 协同式：线程的执行时间由线程本身来控制，线程把自己的工作执行完了之后，要主动通知系统切换到另一个线程上。
  • 抢占式：每个线程将由系统来分配执行时间，线程的切换不由线程本身来决定。
• 线程状态
  • NEW：新建
  • RUNNABLE：运行
  • WAITING：等待其他线程显式唤醒。
  • BLOCKED：堵塞，等待获取一个排他锁，等待进入一个同步区域。
  • TERMINATED：结束
• 线程安全
  • 当多个线程访问一个对象时，如果不用考虑这些线程在运行时环境下的调度和交换执行，也不需要进行额外的同步，或者调用方进行任何其他的协调操作，调用这个对象的行为都可以获得正确的结果，那这个对象就是线程安全的。
  • 不可变：只要一个不可变的对象被正确地构建出来。使用final关键字修饰的基本数据类型；如果共享数据时一个对象，那就需要保证对象的行为不会对其状态产生影响。

10.    线程安全的实现方法

1. 1.     互斥同步：同步是指在多个线程并发访问共享数据时，保证共享数据在同一个时刻只被一条线程使用。互斥方式：临界区、互斥量和信号量。

Synchronized关键字：编译后会在同步块前后分别形成monitorenter和monitorexit这两个字节码指令。这两个指令都需要一个引用类型的参数来指明要锁定和解锁的对象。如果没有明确指定对象参数，那就根据synchronized修饰的是实例方法还是类方法，去取对应的对象实例或Class对象来作为锁对象。

在执行monitorenter指令时，首先尝试获取对象的锁，如果没有被锁定或者当前线程已经拥有了该对象的锁，则将锁计数器加1，相应的执行moniterexit时，将锁计数器减1，当计数器为0时，锁就被释放了。如果获取对象锁失败，则当前线程就要阻塞等待。

ReentrantLock相对synchronized的高级功能：

等待可中断：当持有锁的线程长期不释放锁时，正在等待的线程可以选择放弃等待，改为处理其他事情。

公平锁：多个线程在等待同一个锁时，必须按照申请锁的事件顺序来一次获取锁；而非公平锁在被释放时，任何一个等待锁的线程都有机会获得锁。Synchronized中的锁是非公平锁，ReentrantLock默认也是非公平锁。

锁绑定多个条件：一个ReentrantLock对象可以同时绑定多个Condition对象。

1. 2.     非阻塞同步：

基于冲突检测的乐观并发策略：先进行操作，如果没有其他线程争用共享数据，那操作就成功了；如果共享数据有争用，产生了冲突，那就再进行其他的补偿措施(一般是不断的尝试，直到成功为止)。

AtomicInteger等原子类中提供了方法实现了CAS指令。

1. 3.     无同步方案：

可重入代码：可以在代码执行的任何时刻中断它，转而去执行另一段代码，而在控制权返回后，原来的程序不会出现任何错误。特征：不依赖存储在堆上的数据和公用的系统资源、用到的状态量都由参数传入，不调用非可重入的方法等。如果一个方法，它的返回结果是可以预测的，只要出入了相同的数据，就能返回相同的结果，那它就满足可重入性的要求。

线程本地存储：如果一段代码中所需要的数据必须与其它代码共享，那就看看这些共享数据的代码是否能保证在同一个线程中执行。

A.      ThreadLocal类

ThreadLocal：线程级别的局部变量，为每个使用该变量的线程提供一个独立的变量副本，每个线程修改副本时不影响其他线程对象的副本。ThreadLocal实例通常作为静态私有字段出现在一个类中。

11.    锁优化

1. 1.     自旋锁

为了让线程等待，让线程执行一个忙循环(自旋)。需要物理机器有一个以上的处理器。自旋等待虽然避免了线程切换的开销，带它是要占用处理器时间的，所以如果锁被占用的时间很短，自旋等待的效果就会非常好，反之自旋的线程只会白白消耗处理器资源。自旋次数的默认值是10次，可以使用参数-XX:PreBlockSpin来更改。

自适应自旋锁：自旋的时间不再固定，而是由前一次在同一个锁上的自旋时间及锁的拥有者的状态来决定。

1. 2.     锁清除

指虚拟机即时编译器在运行时，对一些代码上要求同步，但是被检测到不可能存在共享数据竞争的锁进行清除(逃逸分析技术：在堆上的所有数据都不会逃逸出去被其它线程访问到，可以把它们当成栈上数据对待)。

1. 3.     锁粗化

如果虚拟机探测到有一串零碎的操作都对同一个对象加锁，将会把加锁同步的范围扩展到整个操作序列的外部。

HotSpot虚拟机的对象的内存布局：对象头(Object Header)分为两部分信息吗，第一部分(Mark Word)用于存储对象自身的运行时数据，另一个部分用于存储指向方法区对象数据类型的指针，如果是数组的话，还会由一个额外的部分用于存储数组的长度。

32位HotSpot虚拟机中对象未被锁定的状态下，Mark Word的32个Bits空间中25位用于存储对象哈希码，4位存储对象分代年龄，2位存储锁标志位，1位固定为0。

HotSpot虚拟机对象头Mark Word

1. 4.     轻量级锁

在代码进入同步块时，如果此同步对象没有被锁定，虚拟机首先将在当前线程的栈帧中建立一个名为锁记录(Lock Record)的空间，用于存储所对象目前的Mark Word的拷贝。然后虚拟机将使用CAS操作尝试将对象的Mark Word更新为执行Lock Record的指针。如果成功，那么这个线程就拥有了该对象的锁。如果更新操作失败，虚拟机首先会检查对象的Mark Word是否指向当前线程的栈帧，如果是就说明当前线程已经拥有了这个对象的锁，否则说明这个对象已经被其它线程抢占。如果有两条以上的线程争用同一个锁，那轻量级锁就不再有效，要膨胀为重量级锁。

解锁过程：如果对象的Mark Word仍然指向着线程的锁记录，那就用CAS操作把对象当前的Mark Word和和线程中复制的Displaced Mark Word替换回来，如果替换成功，整个过程就完成。如果失败，说明有其他线程尝试过获取该锁，那就要在释放锁的同时，唤醒被挂起的线程。

轻量级锁的依据：对于绝大部分的锁，在整个同步周期内都是不存在竞争的。

传统锁(重量级锁)使用操作系统互斥量来实现的。

1. 5.     偏向锁

目的是消除在无竞争情况下的同步原语，进一步提高程序的运行性能。锁会偏向第一个获得它的线程，如果在接下来的执行过程中，该锁没有被其它线程获取，则持有锁的线程将永远不需要再进行同步。

当锁第一次被线程获取的时候，虚拟机将会把对象头中的标志位设为01，同时使用CAS操作把获取到这个锁的线程的ID记录在对象的Mark Word之中，如果成功，持有偏向锁的线程以后每次进入这个锁相关的同步块时，都可以不进行任何同步操作。

当有另一个线程去尝试获取这个锁时，偏向模式就宣告结束。根据所对象目前是否处于被锁定的状态，撤销偏向后恢复到未锁定或轻量级锁定状态。

12.    内核态和用户态

操作系统的两种运行级别，intel cpu提供-Ring3三种运行模式。

Ring0是留给操作系统代码，设备驱动程序代码使用的，它们工作于系统核心态；而Ring3则给普通的用户程序使用，它们工作在用户态。运行于处理器核心态的代码不受任何的限制，可以自由地访问任何有效地址，进行直接端口访问。而运行于用户态的代码则要受到处理器的诸多检查，它们只能访问映射其地址空间的页表项中规定的在用户态下可访问页面的虚拟地址，且只能对任务状态段（TSS）中I/O许可位图（I/O Permission Bitmap）中规定的可访问端口进行直接访问。

13.    常用方法

1. 1.     object.wait()：

在其他线程调用此对象的notify()或者notifyAll()方法，或超过指定时间量前，当前线程T等待(线程T必须拥有该对象的锁)。线程T被放置在该对象的休息区中，并释放锁。在被唤醒、中断、超时的情况下，从对象的休息区中删除线程T，并重新进行线程调度。一旦线程T获得该对象的锁，该对象上的所有同步申明都被恢复到调用wait()方法时的状态，然后线程T从wait()方法返回。如果当前线程在等待之前或在等待时被任何线程中断，则会抛出 InterruptedException。在按上述形式恢复此对象的锁定状态时才会抛出此异常。在抛出此异常时，当前线程的中断状态被清除。

只有该对象的锁被释放，并不会释放当前线程持有的其他同步资源。

1. 2.     object.notify()

唤醒在此对象锁上等待的单个线程。此方法只能由拥有该对象锁的线程来调用。

1. 3.     Thread.sleep()

在指定的毫秒数内让当前正在执行的线程休眠（暂停执行），此操作受到系统计时器和调度程序精度和准确性的影响。监控状态依然保持、会自动恢复到可运行状态，不会释放对象锁。如果任何线程中断了当前线程。当抛出InterruptedException异常时，当前线程的中断状态被清除。让出CPU分配的执行时间。

thread.join()：在一个线程对象上调用，使当前线程等待这个线程对象对应的线程结束。

Thread.yield()：暂停当前正在执行的线程对象，并执行其他线程。

thread.interrupt()

       中断线程，停止其正在进行的一切。中断一个不处于活动状态的线程不会有任何作用。

      如果线程在调用Object类的wait()方法、或者join()、sleep()方法过程中受阻，则其中断状态将被清除，并收到一个InterruptedException。

Thread.interrupted()：检测当前线程是否已经中断，并且清除线程的中断状态(回到非中断状态)。

thread.isAlive()：如果线程已经启动且尚未终止，则为活动状态。

thread.setDaemon()：需要在start()方法调用之前调用。当正在运行的线程都是后台线程时，Java虚拟机将退出。否则当主线程退出时，其他线程仍然会继续执行。

14.    其他

1. 当调用Object的wait()、notify()、notifyAll()时，如果当前线程没有获得该对象锁，则会抛出IllegalMonitorStateException异常。

1. 如果一个方法申明为synchronized，则等同于在这个方法上调用synchronized(this)。

如果一个静态方法被申明为synchronized，则等同于在这个方法上调用synchronized(类.class)。当一个线程进入同步静态方法中时，其他线程不能进入这个类的任何静态同步方法。

1. 线程成为对象锁的拥有者：
   1. 通过执行此对象的同步实例方法
   2. 通过执行在此对象上进行同步的synchronized语句的正文
   3. 对于Class类型的对象，可以通过执行该类的同步静态方法。

1. 死锁：

死锁就是两个或两个以上的线程被无限的阻塞，线程之间相互等待所需资源。

可能发生在以下情况：

        当两个线程相互调用Thread.join()；

        当两个线程使用嵌套的同步块，一个线程占用了另外一个线程必须的锁，互相等待时被阻塞就有可能出现死锁。

1. 调用了Thread类的start()方法(向CPU申请另一个线程空间来执行run()方法里的代码)，线程的run()方法不一定立即执行，而是要等待JVM进行调度。

run()方法中包含的是线程的主体，也就是这个线程被启动后将要运行的代码。

JAVA多线程高并发

原文：https://www.cnblogs.com/lynn16/p/10697999.html