jason/java_multithread
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update demo for ABA problem

Browse Source
This commit is contained in:
Jason Lu 2025-02-27 17:09:25 +08:00
parent 9578efe639
commit a7a720bc00
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/threaddemo/dataracing/CASByAtomicInteger.java
View File

@ -41,6 +41,11 @@ public class CASByAtomicInteger {
Thread t1 = new Thread(() -> { Thread t1 = new Thread(() -> {
int initValue = unSafeCounter.get(); int initValue = unSafeCounter.get();
System.out.println(STR."Thread 1: Initial value = \{initValue}"); System.out.println(STR."Thread 1: Initial value = \{initValue}");
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
unSafeCounter.compareAndSet(0,20); unSafeCounter.compareAndSet(0,20);
unSafeCounter.compareAndSet(20,0); unSafeCounter.compareAndSet(20,0);
@ -51,13 +56,13 @@ public class CASByAtomicInteger {
Thread t2 = new Thread(() -> { Thread t2 = new Thread(() -> {
int value = unSafeCounter.get(); int value = unSafeCounter.get();
System.out.println("Thread 2: Initial value = " + value);
try { try {
// 等待线程1完成 ABA 操作 // 等待线程1完成 ABA 操作
Thread.sleep(100); Thread.sleep(100);
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} }
System.out.println("Thread 2: Initial value = " + value);
// 尝试 CAS 操作 // 尝试 CAS 操作
boolean success = unSafeCounter.compareAndSet(0, 30); // A -> C boolean success = unSafeCounter.compareAndSet(0, 30); // A -> C