JVM系列之:Contend注解和false-sharing

简介

现代CPU为了提高性能都会有本身的缓存结构，而多核CPU为了同时正常工做，引入了MESI，做为CPU缓存之间同步的协议。MESI虽然很好，可是不当的时候用也可能致使性能的退化。

到底怎么回事呢？一块儿来看看吧。

false-sharing的由来

为了提高处理速度，CPU引入了缓存的概念，咱们先看一张CPU缓存的示意图：

CPU缓存是位于CPU与内存之间的临时数据交换器，它的容量比内存小的多可是交换速度却比内存要快得多。

CPU的读实际上就是层层缓存的查找过程，若是全部的缓存都没有找到的状况下，就是主内存中读取。

为了简化和提高缓存和内存的处理效率，缓存的处理是以Cache Line（缓存行）为单位的。

一次读取一个Cache Line的大小到缓存。

在mac系统中，你可使用sysctl machdep.cpu.cache.linesize来查看cache line的大小。
在linux系统中，使用getconf LEVEL1_DCACHE_LINESIZE来获取cache line的大小。

本机中cache line的大小是64字节。

考虑下面一个对象：

public class CacheLine {
    public  long a;
    public  long b;
}

很简单的对象，经过以前的文章咱们能够指定，这个CacheLine对象的大小应该是12字节的对象头+8字节的long+8字节的long+4字节的补全，总共应该是32字节。

由于32字节< 64字节，因此一个cache line就能够将其包括。

如今问题来了，若是是在多线程的环境中，thread1对a进行累加，而thread2对b进行累加。会发生什么状况呢？

1. 第一步，新建立出来的对象被存储到CPU1和CPU2的缓存cache line中。
2. thread1使用CPU1对对象中的a进行累计。
3. 根据CPU缓存之间的同步协议MESI（这个协议比较复杂，这里就先不展开讲解），由于CPU1对缓存中的cache line进行了修改，因此CPU2中的这个cache line的副本对象将会被标记为I（Invalid）无效状态。
4. thread2使用CPU2对对象中的b进行累加，这个时候由于CPU2中的cache line已经被标记为无效了，因此必须从新从主内存中同步数据。

你们注意，耗时点就在第4步。 虽然a和b是两个不一样的long，可是由于他们被包含在同一个cache line中，最终致使了虽然两个线程没有共享同一个数值对象，可是仍是发送了锁的关联状况。

怎么解决？

那怎么解决这个问题呢？

在JDK7以前，咱们须要使用一些空的字段来手动补全。

public class CacheLine { 
     public  long actualValue; 
     public  long p0, p1, p2, p3, p4, p5, p6, p7; 
     }

像上面那样，咱们手动填充一些空白的long字段，从而让真正的actualValue能够独占一个cache line，就没有这些问题了。

可是在JDK8以后，java文件的编译期会将无用的变量自动忽略掉，那么上面的方法就无效了。

还好，JDK8中引入了sun.misc.Contended注解，使用这个注解会自动帮咱们补全字段。

使用JOL分析

接下来，咱们使用JOL工具来分析一下Contended注解的对象和不带Contended注解的对象有什么区别。

@Test
public void useJol() {
        log.info("{}", ClassLayout.parseClass(CacheLine.class).toPrintable());
        log.info("{}", ClassLayout.parseInstance(new CacheLine()).toPrintable());
        log.info("{}", ClassLayout.parseClass(CacheLinePadded.class).toPrintable());
        log.info("{}", ClassLayout.parseInstance(new CacheLinePadded()).toPrintable());
    }

注意，在使用JOL分析Contended注解的对象时候，须要加上 -XX:-RestrictContended参数。

同时能够设置-XX:ContendedPaddingWidth 来控制padding的大小。

INFO com.flydean.CacheLineJOL - com.flydean.CacheLine object internals:
 OFFSET  SIZE   TYPE DESCRIPTION                               VALUE
      0     4        (object header)                           05 00 00 00 (00000101 00000000 00000000 00000000) (5)
      4     4        (object header)                           00 00 00 00 (00000000 00000000 00000000 00000000) (0)
      8     4        (object header)                           d0 29 17 00 (11010000 00101001 00010111 00000000) (1518032)
     12     4        (alignment/padding gap)                  
     16     8   long CacheLine.valueA                          0
     24     8   long CacheLine.valueB                          0
Instance size: 32 bytes
Space losses: 4 bytes internal + 0 bytes external = 4 bytes total

INFO com.flydean.CacheLineJOL - com.flydean.CacheLinePadded object internals:
 OFFSET  SIZE   TYPE DESCRIPTION                               VALUE
      0     4        (object header)                           05 00 00 00 (00000101 00000000 00000000 00000000) (5)
      4     4        (object header)                           00 00 00 00 (00000000 00000000 00000000 00000000) (0)
      8     4        (object header)                           d2 5d 17 00 (11010010 01011101 00010111 00000000) (1531346)
     12     4        (alignment/padding gap)                  
     16     8   long CacheLinePadded.b                         0
     24   128        (alignment/padding gap)                  
    152     8   long CacheLinePadded.a                         0
Instance size: 160 bytes
Space losses: 132 bytes internal + 0 bytes external = 132 bytes total

咱们看到使用了Contended的对象大小是160字节。直接填充了128字节。

Contended在JDK9中的问题

sun.misc.Contended是在JDK8中引入的，为了解决填充问题。

可是你们注意，Contended注解是在包sun.misc，这意味着通常来讲是不建议咱们直接使用的。

虽然不建议你们使用，可是仍是能够用的。

但若是你使用的是JDK9-JDK14,你会发现sun.misc.Contended没有了！

由于JDK9引入了JPMS（Java Platform Module System），它的结构跟JDK8已经彻底不同了。

通过个人研究发现，sun.misc.Contended, sun.misc.Unsafe，sun.misc.Cleaner这样的类都被移到了jdk.internal.**中，而且是默认不对外使用的。

那么有人要问了，咱们换个引用的包名是否是就好了？

import jdk.internal.vm.annotation.Contended；

抱歉仍是不行。

error: package jdk.internal.vm.annotation is not visible
  @jdk.internal.vm.annotation.Contended
                  ^
  (package jdk.internal.vm.annotation is declared in module
    java.base, which does not export it to the unnamed module)

好，咱们找到问题所在了，由于咱们的代码并无定义module，因此是一个默认的“unnamed” module,咱们须要把java.base中的jdk.internal.vm.annotation使unnamed module可见。

要实现这个目标，咱们能够在javac中添加下面的flag：

--add-exports java.base/jdk.internal.vm.annotation=ALL-UNNAMED

好了，如今咱们能够正常经过编译了。

padded和unpadded性能对比

上面咱们看到padded对象大小是160字节，而unpadded对象的大小是32字节。

对象大了，运行的速度会不慢呢？

实践出真知，咱们使用JMH工具在多线程环境中来对其进行测试：

@State(Scope.Benchmark)
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.NANOSECONDS)
@Fork(value = 1, jvmArgsPrepend = "-XX:-RestrictContended")
@Warmup(iterations = 10)
@Measurement(iterations = 25)
@Threads(2)
public class CacheLineBenchMark {

    private CacheLine cacheLine= new CacheLine();
    private CacheLinePadded cacheLinePadded = new CacheLinePadded();

    @Group("unpadded")
    @GroupThreads(1)
    @Benchmark
    public long updateUnpaddedA() {
        return cacheLine.a++;
    }

    @Group("unpadded")
    @GroupThreads(1)
    @Benchmark
    public long updateUnpaddedB() {
        return cacheLine.b++;
    }

    @Group("padded")
    @GroupThreads(1)
    @Benchmark
    public long updatePaddedA() {
        return cacheLinePadded.a++;
    }

    @Group("padded")
    @GroupThreads(1)
    @Benchmark
    public long updatePaddedB() {
        return cacheLinePadded.b++;
    }

    public static void main(String[] args) throws RunnerException {
        Options opt = new OptionsBuilder()
                .include(CacheLineBenchMark.class.getSimpleName())
                .build();
        new Runner(opt).run();
    }
}

上面的JMH代码中，咱们使用两个线程分别对A和B进行累计操做，看下最后的运行结果：

从结果看来虽然padded生成的对象比较大，可是由于A和B在不一样的cache line中，因此不会出现不一样的线程去主内存取数据的状况，所以要执行的比较快。

Contended在JDK中的使用

其实Contended注解在JDK源码中也有使用，不算普遍，可是都很重要。

好比在Thread中的使用：

好比在ConcurrentHashMap中的使用：

其余使用的地方：Exchanger,ForkJoinPool,Striped64。

感兴趣的朋友能够仔细研究一下。

总结

Contented从最开始的sun.misc到如今的jdk.internal.vm.annotation，都是JDK内部使用的class，不建议你们在应用程序中使用。

这就意味着咱们以前使用的方式是不正规的，虽然可以达到效果，可是不是官方推荐的。那么咱们还有没有什么正规的办法来解决false-sharing的问题呢？

有知道的小伙伴欢迎留言给我讨论！

本文做者：flydean程序那些事

本文连接：http://www.flydean.com/jvm-contend-false-sharing/

本文来源：flydean的博客

欢迎关注个人公众号:程序那些事，更多精彩等着您！