熟悉 Java 并发编程的都知道,JMM(Java 内存模型) 中的 happens-before(简称 hb)规则,该规则定义了 Java 多线程操做的有序性和可见性,防止了编译器重排序对程序结果的影响。按照官方的说法:java
当一个变量被多个线程读取而且至少被一个线程写入时,若是读操做和写操做没有 HB 关系,则会产生数据竞争问题。 要想保证操做 B
的线程看到操做 A
的结果(不管 A
和 B
是否在一个线程),那么在 A
和 B
之间必须知足 HB 原则,若是没有,将有可能致使重排序。 当缺乏 HB 关系时,就可能出现重排序问题。编程
这个你们都很是熟悉了应该,大部分书籍和文章都会介绍,这里稍微回顾一下:小程序
其中,传递规则我加粗了,这个规则相当重要。如何熟练的使用传递规则是实现同步的关键。缓存
而后,再换个角度解释 HB:当一个操做 A HB 操做 B,那么,操做 A 对共享变量的操做结果对操做 B 都是可见的。安全
同时,若是 操做 B HB 操做 C,那么,操做 A 对共享变量的操做结果对操做 B 都是可见的。多线程
而实现可见性的原理则是 cache protocol 和 memory barrier。经过缓存一致性协议和内存屏障实现可见性。并发
在 Doug Lea 著做 《Java Concurrency in Practice》中,有下面的描述:app
书中提到:经过组合 hb 的一些规则,能够实现对某个未被锁保护变量的可见性。ui
但因为这个技术对语句的顺序很敏感,所以容易出错。spa
楼主接下来,将演示如何经过 volatile 规则和程序次序规则实现对一个变量同步。
来一个熟悉的例子:
class ThreadPrintDemo{ static int num = 0; static volatile boolean flag = false; public static void main(String[] args){ Thread t1 = new Thread(() -> { for (; 100 > num; ) { if (!flag && (num == 0 || ++num % 2 == 0)) { System.out.println(num); flag = true; } } } ); Thread t2 = new Thread(() -> { for (; 100 > num; ) { if (flag && (++num % 2 != 0)) { System.out.println(num); flag = false; } } } ); t1.start(); t2.start(); } }
这段代码的做用是两个线程间隔打印出 0 – 100 的数字。
熟悉并发编程的同窗确定要说了,这个 num 变量没有使用 volatile,会有可见性问题,即:t1 线程更新了 num,t2 线程没法感知。
哈哈,楼主刚开始也是这么认为的,但最近经过研究 HB 规则,我发现,去掉 num 的 volatile 修饰也是能够的。
咱们分析一下,楼主画了一个图:
咱们分析这个图:
程序次序规则的
。也就是 1 HB 2.程序次序规则
,也就是 3 HB 4.传递性规则
,1 确定 HB 4. 因此,1 的修改对 4来讲都是可见的。注意:HB 规则保证上一个操做的结果对下一个操做都是可见的。
因此,上面的小程序中,线程 A 对 num 的修改,线程 B 是彻底感知的 —— 即便 num 没有使用 volatile 修饰。
这样,咱们就借助 HB 原则实现了对一个变量的同步操做,也就是在多线程环境中,保证了并发修改共享变量的安全性。而且没有对这个变量使用 Java 的原语:volatile 和 synchronized 和 CAS(假设算的话)。
这可能看起来不安全(实际上安全),也好像不太容易理解。由于这一切都是 HB 底层的 cache protocol 和 memory barrier 实现的。
static int a = 1; public static void main(String[] args){ Thread tb = new Thread(() -> { a = 2; }); Thread ta = new Thread(() -> { try { tb.join(); } catch (InterruptedException e) { //NO } System.out.println(a); }); ta.start(); tb.start(); }
2.利用线程 start 规则实现:
static int a = 1; public static void main(String[] args){ Thread tb = new Thread(() -> { System.out.println(a); }); Thread ta = new Thread(() -> { tb.start(); a = 2; }); ta.start(); }
这两个操做,也能够保证变量 a 的可见性。
确实有点颠覆以前的观念。以前的观念中,若是一个变量没有被 volatile 修饰或 final 修饰,那么他在多线程下的读写确定是不安全的 —— 由于会有缓存,致使读取到的不是最新的。
然而,经过借助 HB,咱们能够实现。
虽然本文标题是经过 happens-before 实现对共享变量的同步操做,但主要目的仍是更深入的理解 happen-before,理解他的 happens-before 概念其实就是保证多线程环境中,上一个操做对下一个操做的有序性和操做结果的可见性。
同时,经过灵活的使用传递性规则,再对规则进行组合,就能够将两个线程进行同步 —— 实现指定的共享变量不使用原语也能够保证可见性。虽然这好像不是很易读,但也是一种尝试。
关于如何组合使用规则实现同步,Doug Lea 在 JUC 中给出了实践。
例如老版本的 FutureTask 的内部类 Sync(已消失),经过 tryReleaseShared 方法修改 volatile 变量,tryAcquireShared 读取 volatile 变量,这是利用了 volatile 规则;
经过在 tryReleaseShared 以前设置非 volatile 的 result 变量,而后在 tryAcquireShared 以后读取 result 变量,这是利用了程序次序规则。
从而保证 result 变量的可见性。和咱们的第一个例子相似:利用程序次序规则和 volatile 规则实现普通变量可见性。
而 Doug Lea 本身也说了,这个“借助”技术很是容易出错,要谨慎使用。但在某些状况下,这种“借助”是很是合理的。
实际上,BlockingQueue 也是“借助”了 happens-before 的规则。还记得 unlock 规则吗?当 unlock 发生后,内部元素必定是可见的。
而类库中还有其余的操做也“借助”了 happens-before 原则:并发容器,CountDownLatch,Semaphore,Future,Executor,CyclicBarrier,Exchanger 等。
总而言之,言而总之:
happens-before 原则是 JMM 的核心所在,只有知足了 hb 原则才能保证有序性和可见性,不然编译器将会对代码重排序。hb 甚至将 lock 和 volatile 也定义了规则。
经过适当的对 hb 规则的组合,能够实现对普通共享变量的正确使用。