逃逸分析是“一种确定指针动态范围的方法,它可以分析在程序的哪些地方可以访问到指针。
在 Java 虚拟机的即时编译语境下,逃逸分析将判断新建的对象是否会逃逸。即时编译器判断对象逃逸的依据有两个:一是看对象是否被存入堆中,二是看对象是否作为方法调用的调用者或者参数。
前者很好理解,一旦对象被存入堆中,其他线程便能获得该对象的引用。即时编译器因此无法追踪所有使用该对象的代码位置。
关于后者,由于 Java 虚拟机的即时编译器是以方法为单位的,对于方法中未被内联的方法调用,即时编译器会将其当成未知代码,毕竟它无法确认该方法调用会不会将调用者或所传入的参数存储至堆中。因此,我们可以认为方法调用的调用者以及参数是逃逸的。
即时编译器会根据逃逸分析的结果进行优化,如锁消除以及标量替换。
锁消除
如果即时编译器能够证明锁对象不逃逸,那么对该锁对象的加锁、解锁操作没有意义。这是因为其他线程并不能获得该锁对象,因此也不可能对其进行加锁。在这种情况下,即时编译器可以消除对该不逃逸锁对象的加锁、解锁操作。
关闭默认开启的逃逸分析,命令如下:
java -XX:-DoEscapeAnalysis
- public class SynchronizeEscapeTest {
-
- public static void main(String[] args) {
- for (int i = 0; i < 10; i++) {
- long start = System.currentTimeMillis();
- for (int j = 0; j < 10_000_000; j++) {
- SynchronizeEscapeTest synchronizeEscapeTestc = new SynchronizeEscapeTest();
- synchronizeEscapeTestc.eliminate();
- }
- System.out.println(System.currentTimeMillis() - start + "ms");
- }
-
- }
-
- public void eliminate() {
- synchronized (new Object()) {
-
- }
- }
- }
- 耗时时长
- 255ms
- 237ms
- 187ms
- 232ms
- 148ms
- 128ms
- 142ms
- 210ms
- 171ms
- 211ms
开启默认逃逸分析
java -XX:+DoEscapeAnalysis
- 耗时时长
- 14ms
- 9ms
- 4ms
- 3ms
- 4ms
- 3ms
- 4ms
- 3ms
- 3ms
- 4ms
synchronized (new Object()) {} 由于其他线程不能获得该锁对象,因此也无法基于该锁对象构造两个线程之间的 happens-before 规则
synchronized (escapedObject) {}则不然。由于其他线程可能会对逃逸了的对象escapedObject进行加锁操作,从而构造了两个线程之间的 happens-before 关系。因此即时编译器至少需要为这段代码生成一条刷新缓存的内存屏障指令。
问题一:
开启逃逸分析后,
synchronized (new Object()) {} 会不会在堆中创建对象实例?
标量替换
我们知道,Java 虚拟机中对象都是在堆上分配的,而堆上的内容对任何线程都是可见的。与此同时,Java 虚拟机需要对所分配的堆内存进行管理,并且在对象不再被引用时回收其所占据的内存
如果逃逸分析能够证明某些新建的对象不逃逸,那么 Java 虚拟机完全可以将其分配至栈上,并且在 new 语句所在的方法退出时,通过弹出当前方法的栈桢来自动回收所分配的内存空间。这样一来,我们便无须借助垃圾回收器来处理不再被引用的对象。不过,由于实现起来需要更改大量假设了“对象只能堆分配”的代码,因此 HotSpot 虚拟机并没有采用栈上分配,而是使用了标量替换这么一项技术。所谓的标量,就是仅能存储一个值的变量,比如 Java 代码中的局部变量。与之相反,聚合量则可能同时存储多个值,其中一个典型的例子便是 Java 对象。
foreach语法糖
我们知道,Java 中Iterable对象的 foreach 循环遍历是一个语法糖,Java 编译器会将该语法糖编译为调用Iterable对象的iterator方法,并用所返回的Iterator对象的hasNext以及next方法,来完成遍历。
-
- public static void forEach(ArrayList<Object> list, Consumer<Object> f) {
- for (Object obj : list) {
- f.accept(obj);
- }
- }
- public static void foreach(java.util.ArrayList<java.lang.Object>, java.util.function.Consumer<java.lang.Object>);
- Code:
- 0: aload_0
- 1: invokevirtual #9 // Method java/util/ArrayList.iterator:()Ljava/util/Iterator;
- 4: astore_2
- 5: aload_2
- 6: invokeinterface #10, 1 // InterfaceMethod java/util/Iterator.hasNext:()Z
- 11: ifeq 31
- 14: aload_2
- 15: invokeinterface #11, 1 // InterfaceMethod java/util/Iterator.next:()Ljava/lang/Object;
- 20: astore_3
- 21: aload_1
- 22: aload_3
- 23: invokeinterface #12, 2 // InterfaceMethod java/util/function/Consumer.accept:(Ljava/lang/Object;)V
- 28: goto 5
- 31: return
等价实现代码
- public static void foreach(ArrayList<Object> list, Consumer<Object> f) {
- Iterator var2 = list.iterator();
-
- while(var2.hasNext()) {
- Object obj = var2.next();
- f.accept(obj);
- }
-
- }
ArrayList$Itr
-
- public class ArrayList ... {
- public Iterator<E> iterator() {
- return new Itr();
- }
- private class Itr implements Iterator<E> {
- int cursor; // index of next element to return
- int lastRet = -1; // index of last element returned; -1 if no such
- int expectedModCount = modCount;
- ...
- public boolean hasNext() {
- return cursor != size;
- }
- @SuppressWarnings("unchecked")
- public E next() {
- checkForComodification();
- int i = cursor;
- if (i >= size)
- throw new NoSuchElementException();
- Object[] elementData = ArrayList.this.elementData;
- if (i >= elementData.length)
- throw new ConcurrentModificationException();
- cursor = i + 1;
- return (E) elementData[lastRet = i];
- }
- ...
- final void checkForComodification() {
- if (modCount != expectedModCount)
- throw new ConcurrentModificationException();
- }
- }
- }
问题二:
如果在热点代码中使用foreach循环,会不会对Java堆有压力。
关闭默认开启的逃逸分析,命令如下:
java -XX:-DoEscapeAnalysis
-Xlog:gc
- public class EscapeTest {
-
- public static void main(String[] args) {
-
- ArrayList<Object> list = new ArrayList<>();
- for (int i = 0; i < 100; i++) {
- list.add(i);
- }
-
- for (int i = 0; i < 400_000_000; i++) {
- foreach(list,obj -> {});
- }
-
- }
-
- public static void foreach(ArrayList<Object> list, Consumer<Object> f) {
- for (Object obj : list) {
- f.accept(obj);
- }
- }
-
- }
GC日志和耗时
- [0.013s][info][gc] Using G1
- [8.675s][info][gc] GC(126) Pause Young (Normal) (G1 Evacuation Pause) 93M->1M(154M) 0.199ms
- [8.738s][info][gc] GC(127) Pause Young (Normal) (G1 Evacuation Pause) 93M->1M(154M) 0.193ms
- [8.801s][info][gc] GC(128) Pause Young (Normal) (G1 Evacuation Pause) 93M->1M(154M) 0.192ms
- [8.866s][info][gc] GC(129) Pause Young (Normal) (G1 Evacuation Pause) 93M->1M(154M) 0.196ms
- [8.931s][info][gc] GC(130) Pause Young (Normal) (G1 Evacuation Pause) 93M->1M(154M) 0.197ms
- [8.994s][info][gc] GC(131) Pause Young (Normal) (G1 Evacuation Pause) 93M->1M(154M) 0.189ms
- [9.057s][info][gc] GC(132) Pause Young (Normal) (G1 Evacuation Pause) 93M->1M(154M) 0.187ms
- [9.121s][info][gc] GC(133) Pause Young (Normal) (G1 Evacuation Pause) 93M->1M(154M) 0.200ms
- [9.185s][info][gc] GC(134) Pause Young (Normal) (G1 Evacuation Pause) 93M->1M(154M) 0.189ms
- 8951ms
开启默认逃逸分析
java -XX:+DoEscapeAnalysis -Xlog:gc
GC日志和耗时
- [0.014s][info][gc] Using G1
- 1910ms
如果使用下面的代码会有什么问题
-
- public void forEach(ArrayList<Object> list, Consumer<Object> f) {
- for (int i = 0; i < list.size(); i++) {
- f.accept(list.get(i));
- }
- }
理想情况下,即时编译器能够内联对ArrayList$Itr构造器的调用,对hasNext以及next方法的调用,以及当内联了Itr.next方法后,对checkForComodification方法的调用
如果这些方法调用均能够被内联,那么结果将近似于下面这段伪代码:
-
- public void forEach(ArrayList<Object> list, Consumer<Object> f) {
- Itr iter = new Itr; // 注意这里是new指令
- iter.cursor = 0;
- iter.lastRet = -1;
- iter.expectedModCount = list.modCount;
- while (iter.cursor < list.size) {
- if (list.modCount != iter.expectedModCount)
- throw new ConcurrentModificationException();
- int i = iter.cursor;
- if (i >= list.size)
- throw new NoSuchElementException();
- Object[] elementData = list.elementData;
- if (i >= elementData.length)
- throw new ConcurrentModificationException();
- iter.cursor = i + 1;
- iter.lastRet = i;
- Object obj = elementData[i];
- f.accept(obj);
- }
- }
可以看到,这里新建的ArrayList$Itr实例既没有被存入任何字段之中,也没有作为任何方法调用的调用者或者参数。因此,逃逸分析将断定该实例不逃逸。通过使用标量替换优化技术,可以把原本对对象的字段的访问,替换为一个个局部变量的访问。例如前面经过内联之后的 forEach 代码就可以被替换为如下代码:
-
- public void forEach(ArrayList<Object> list, Consumer<Object> f) {
- // Itr iter = new Itr; // 经过标量替换后该分配无意义,可以被优化掉
- int cursor = 0; // 标量替换
- int lastRet = -1; // 标量替换
- int expectedModCount = list.modCount; // 标量替换
- while (cursor < list.size) {
- if (list.modCount != expectedModCount)
- throw new ConcurrentModificationException();
- int i = cursor;
- if (i >= list.size)
- throw new NoSuchElementException();
- Object[] elementData = list.elementData;
- if (i >= elementData.length)
- throw new ConcurrentModificationException();
- cursor = i + 1;
- lastRet = i;
- Object obj = elementData[i];
- f.accept(obj);
- }
- }
可以看到,原本需要在内存中连续分布的对象,现已被拆散为一个个单独的字段cursor,lastRet,以及expectedModCount。这些字段既可以存储在栈上,也可以直接存储在寄存器中。而该对象的对象头信息则直接消失了,不再被保存至内存之中。
由于该对象没有被实际分配,因此和栈上分配一样,它同样可以减轻垃圾回收的压力。与栈上分配相比,它对字段的内存连续性不做要求,而且,这些字段甚至可以直接在寄存器中维护,无须浪费任何内存空间。
部分逃逸分析
C2编译器的逃逸分析与控制流无关,相对来说比较简单。Graal编译器则引入了一个与控制流有关的逃逸分析,名为部分逃逸分析。它解决了所新建的实例仅在部分程序路径中逃逸的情况。
-
- public static void bar(boolean condition) {
- Object foo = new Object();
- if (condition) {
- foo.hashCode();
- }
- }
- // 可以手工优化为:
- public static void bar(boolean condition) {
- if (condition) {
- Object foo = new Object();
- foo.hashCode();
- }
- }
假设 if 语句的条件成立的可能性只有 1%,那么在 99% 的情况下,程序没有必要新建对象。其手工优化的版本正是部分逃逸分析想要自动达到的成果。
部分逃逸分析将根据控制流信息,判断出新建对象仅在部分分支中逃逸,并且将对象的新建操作推延至对象逃逸的分支中。与 C2 所使用的逃逸分析相比,Graal 所使用的部分逃逸分析能够优化更多的情况,不过它编译时间也更长一些。
测试Graal编译器的部分逃逸分析
启用Graal
-XX:+UnlockExperimentalVMOptions -XX:+UseJVMCICompiler -X:log:gc
- public class PartialEscapeTest {
- long placeHolder0;
- long placeHolder1;
- long placeHolder2;
- long placeHolder3;
- long placeHolder4;
- long placeHolder5;
- long placeHolder6;
- long placeHolder7;
- long placeHolder8;
- long placeHolder9;
- long placeHoldera;
- long placeHolderb;
- long placeHolderc;
- long placeHolderd;
- long placeHoldere;
- long placeHolderf;
- public static void bar(boolean condition) {
- PartialEscapeTest foo = new PartialEscapeTest();
- if (condition) {
- foo.hashCode();
- }
- }
- public static void main(String[] args) {
- for (int i = 0; i < Integer.MAX_VALUE; i++) {
- bar(i % 100 == 0);
- }
- }
- }
GC日志
- [0.012s][info ][gc] Using G1
- [3.186s][info ][gc] GC(64) Pause Young (Normal) (G1 Evacuation Pause) 482M->5M(797M) 2.010ms
- [3.238s][info ][gc] GC(65) Pause Young (Normal) (G1 Evacuation Pause) 482M->5M(797M) 1.863ms
- [3.289s][info ][gc] GC(66) Pause Young (Normal) (G1 Evacuation Pause) 482M->5M(797M) 2.601ms
- [3.346s][info ][gc] GC(67) Pause Young (Normal) (G1 Evacuation Pause) 482M->5M(797M) 1.679ms
- [3.399s][info ][gc] GC(68) Pause Young (Normal) (G1 Evacuation Pause) 482M->5M(797M) 1.312ms
- [3.718s][info ][gc] GC(69) Pause Young (Normal) (G1 Evacuation Pause) 482M->6M(797M) 1.925ms
- [4.556s][info ][gc] GC(70) Pause Young (Normal) (G1 Evacuation Pause) 483M->6M(797M) 3.850ms
- [5.375s][info ][gc] GC(71) Pause Young (Normal) (G1 Evacuation Pause) 482M->7M(797M) 5.514ms
- [6.182s][info ][gc] GC(72) Pause Young (Normal) (G1 Evacuation Pause) 483M->7M(797M) 5.957ms
- [6.985s][info ][gc] GC(73) Pause Young (Normal) (G1 Evacuation Pause) 483M->7M(797M) 1.327ms
- [7.793s][info ][gc] GC(74) Pause Young (Normal) (G1 Evacuation Pause) 483M->7M(797M) 1.386ms
如果不启用Graal
-XX:+UnlockExperimentalVMOptions -X:log:gc
GC日志
- [0.013s][info ][gc] Using G1
- [17.839s][info ][gc] GC(760) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.467ms
- [17.861s][info ][gc] GC(761) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.607ms
- [17.885s][info ][gc] GC(762) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.672ms
- [17.909s][info ][gc] GC(763) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.587ms
- [17.933s][info ][gc] GC(764) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.698ms
- [17.956s][info ][gc] GC(765) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.547ms
- [17.979s][info ][gc] GC(766) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.538ms
- [18.000s][info ][gc] GC(767) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.437ms
- [18.021s][info ][gc] GC(768) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.440ms
- [18.042s][info ][gc] GC(769) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.456ms
- [18.063s][info ][gc] GC(770) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.482ms
- [18.087s][info ][gc] GC(771) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.955ms
- [18.112s][info ][gc] GC(772) Pause Young (Normal) (G1 Evacuation Pause) 397M->1M(661M) 0.748ms
问题三:
如果经过即时编译器分析后对象不会发生逃逸,还会在堆中创建对象吗