多线程（72）False Sharing

2024-04-25 13:04

文章标签 多线程 false 72 sharing

本文主要是介绍多线程（72）False Sharing，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

False Sharing（伪共享）是并发编程中的一个性能问题，它发生在多个线程访问并修改相互独立的变量时，这些变量恰好位于同一个缓存行（Cache Line）内。现代CPU为了提高访问内存的速度，会将内存分成一系列的缓存行，通常大小为64字节，并且以缓存行为单位将数据从主存（RAM）加载到CPU缓存中。当一个线程修改了一个缓存行内的数据时，处于同一缓存行的其他数据也会被标记为无效，导致其他线程在访问自己的变量时不得不重新从主存中加载整个缓存行，即使它们只是想要读取自己的独立变量。

举个例子

考虑以下Java代码，其中模拟了两个线程并发更新两个独立变量的情况：

public class FalseSharingExample implements Runnable {public final static int NUM_THREADS = 2; // 线程数public final static long ITERATIONS = 500L * 1000L * 1000L;private final int arrayIndex;private static VolatileLong[] longs = new VolatileLong[NUM_THREADS];static {for (int i = 0; i < longs.length; i++) {longs[i] = new VolatileLong();}}public FalseSharingExample(final int arrayIndex) {this.arrayIndex = arrayIndex;}public static void main(final String[] args) throws Exception {final long start = System.nanoTime();runTest();System.out.println("Duration = " + (System.nanoTime() - start));}private static void runTest() throws InterruptedException {Thread[] threads = new Thread[NUM_THREADS];for (int i = 0; i < threads.length; i++) {threads[i] = new Thread(new FalseSharingExample(i));}for (Thread t : threads) {t.start();}for (Thread t : threads) {t.join();}}public void run() {long i = ITERATIONS + 1;while (0 != --i) {longs[arrayIndex].value = i;}}public final static class VolatileLong {public volatile long value = 0L;}
}

在这个例子中，有两个线程分别更新数组longs中的两个独立元素。由于VolatileLong对象很小，它们很可能被放置在同一个缓存行中。这意味着当一个线程更新它的value变量时，可能会导致另一个线程的缓存行无效，因此增加了不必要的内存访问延迟。

解决伪共享

解决伪共享的一种常见方法是通过增加填充（Padding）来强制每个被频繁写入的变量都位于不同的缓存行中。Java 8引入了@Contended注解，但默认是禁用的，您需要在JVM启动时通过-XX:-RestrictContended来启用它。下面是一个增加了填充以避免伪共享的示例：

public final static class PaddedVolatileLong {// 增加填充public volatile long p1, p2, p3, p4, p5, p6 = 7L;public volatile long value = 0L;// 对齐到另一个缓存行，避免伪共享public volatile long q1, q2, q3, q4, q5, q6 = 7L;
}