更新

Author: jujunchen

2.Java Concurrent.md

@@ -284,6 +284,7 @@ public class CopyOnWriteArrayListTest {
     pool-1-thread-2
     pool-1-thread-2，执行结束
     pool-1-thread-1，执行结束
+    # 等待所有线程都执行完成
     ```
 
 
@@ -310,7 +311,7 @@ public class PhaserTest {
 
        executor.submit(() -> {
            System.out.println(Thread.currentThread().getName() + " step2");
-           phaser.arrive(d);
+           phaser.arrive();
        });
 
        //等同await()
@@ -404,6 +405,8 @@ Thread2:1
 
 什么时候使用volatile?
 
+- 有一个变量，这个变量需要被多线程检查某个条件，此时使用volatile确保每次都从主内存读取
+
 - 写入变量值不依赖变量的当前值。因为如果依赖当前值，将是获取-计算-写入三步操作，这三步操作不是原子性的，而volatile不保证原子性
 
 - 读写变量值时没有加锁。因为加锁已经保证了内存可见性，没必要再使用volatile
@@ -446,8 +449,6 @@ Thread2:1
 
 > @Contended注解只用于Java核心类，如果用户类路径下的类要使用这个注解，需要添加JVM参数：-XX:-RestrictContended。默认填充宽度为128，需要自定义宽度设置 -XX:ContendedPaddingWidth参数
 
-> CPU缓存行详细说明：https://mp.weixin.qq.com/s/yosnZr0bDdLrhmpnX8TY5A
-
 ### 原子操作类
 
  **AtomicBoolean**
@@ -686,46 +687,53 @@ public void test1() {
 AtomicStampedReference解决ABA问题,通过维护一个版本号
 
 ```java
-@SneakyThrows
-@Test
-public void test2() {
-    AtomicStampedReference<Integer> atomicStampedReference = new AtomicStampedReference(10,1);
-
-    CountDownLatch countDownLatch = new CountDownLatch(2);
+   //AtomicStampedReference,通过维护一个版本号
+    @SneakyThrows
+    @Test
+    public void test2() {
+        AtomicStampedReference<Integer> atomicStampedReference = new AtomicStampedReference(10,1);
 
-    new Thread(() -> {
-        System.out.println(Thread.currentThread().getName() + " 第一次版本：" + atomicStampedReference.getStamp());
-        atomicStampedReference.compareAndSet(10, 11, atomicStampedReference.getStamp(), atomicStampedReference.getStamp() + 1);
-        System.out.println(Thread.currentThread().getName() + " 第二次版本：" + atomicStampedReference.getStamp());
-        atomicStampedReference.compareAndSet(11, 10, atomicStampedReference.getStamp(), atomicStampedReference.getStamp() + 1);
-        System.out.println(Thread.currentThread().getName() + " 第三次版本：" + atomicStampedReference.getStamp());
-        countDownLatch.countDown();
-    }).start();
+        CountDownLatch countDownLatch = new CountDownLatch(2);
 
-    new Thread(() -> {
-        System.out.println(Thread.currentThread().getName() + " 第一次版本：" + atomicStampedReference.getStamp());
-        try {
-            TimeUnit.SECONDS.sleep(2);
-            boolean isSuccess = atomicStampedReference.compareAndSet(10,12, atomicStampedReference.getStamp(), atomicStampedReference.getStamp() + 1);
-            System.out.println(Thread.currentThread().getName() + " 修改是否成功：" + isSuccess + " 当前版本：" + atomicStampedReference.getStamp() + " 当前值：" + atomicStampedReference.getReference());
+        new Thread(() -> {
+            //使用第一次获取的版本，因为不知道有其他线程偷摸改了
+            int stamp = atomicStampedReference.getStamp();
+            System.out.println(Thread.currentThread().getName() + " 第一次版本：" + stamp);
+            try {
+                //等待一下
+                TimeUnit.SECONDS.sleep(2);
+                //这个线程打算修改10->12
+                boolean isSuccess = atomicStampedReference.compareAndSet(10,12, stamp, stamp + 1);
+                System.out.println(Thread.currentThread().getName() + " 修改是否成功：" + isSuccess + " 当前版本：" + atomicStampedReference.getStamp() + " 当前值：" + atomicStampedReference.getReference());
+                countDownLatch.countDown();
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }).start();
+
+        new Thread(() -> {
+            //这个线程偷摸的把10->11->10
+            System.out.println(Thread.currentThread().getName() + " 第一次版本：" + atomicStampedReference.getStamp());
+            atomicStampedReference.compareAndSet(10, 11, atomicStampedReference.getStamp(), atomicStampedReference.getStamp() + 1);
+            System.out.println(Thread.currentThread().getName() + " 第二次版本：" + atomicStampedReference.getStamp());
+            atomicStampedReference.compareAndSet(11, 10, atomicStampedReference.getStamp(), atomicStampedReference.getStamp() + 1);
+            System.out.println(Thread.currentThread().getName() + " 第三次版本：" + atomicStampedReference.getStamp());
             countDownLatch.countDown();
-        } catch (InterruptedException e) {
-            e.printStackTrace();
-        }
-    }).start();
+        }).start();
 
-    countDownLatch.await();
-}
+
+        countDownLatch.await();
+    }
 
 ```
 
 ```java
 //输出
+Thread-1 第一次版本：1
 Thread-0 第一次版本：1
-Thread-0 第二次版本：2
-Thread-0 第三次版本：3
-Thread-1 第一次版本：3
-Thread-1 修改是否成功：true 当前版本：4 当前值：12
+Thread-1 第二次版本：2
+Thread-1 第三次版本：3
+Thread-0 修改是否成功：false 当前版本：3 当前值：10
 ```
 
 AtomicMarkableReference 通过标志位,由于其标志位只有true和false，如果每次更新都变更标志位，在第三次的时候标志位还是跟第一次一样，并没有解决ABA问题