From 39d2b8b43f11084a700aeb91138598d3680abaf7 Mon Sep 17 00:00:00 2001
From: Bunny <1319900154@qq.com>
Date: Mon, 20 Jan 2025 20:33:42 +0800
Subject: [PATCH] feat: AtomicExample02

---
 .../java/cn/bunny/atomic/AtomicExample01.java | 82 +++++++++++++++++++
 .../java/cn/bunny/atomic/AtomicExample02.java | 43 ++++++++++
 .../java/cn/bunny/atomic/AtomicExample04.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample05.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample06.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample07.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample08.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample09.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample10.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample11.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample12.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample13.java |  4 +
 .../java/cn/bunny/atomic/AtomicExample14.java |  4 +
 .../atomic/reference/AtomicExample03.java     | 31 +++++++
 .../cn/bunny/atomic/reference/DebitCard.java  | 44 ++++++++++
 15 files changed, 244 insertions(+)
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample01.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample02.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample04.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample05.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample06.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample07.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample08.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample09.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample10.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample11.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample12.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample13.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/AtomicExample14.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/reference/AtomicExample03.java
 create mode 100644 multithreading1/src/main/java/cn/bunny/atomic/reference/DebitCard.java

diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample01.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample01.java
new file mode 100644
index 0000000..263b20d
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample01.java
@@ -0,0 +1,82 @@
+package cn.bunny.atomic;
+
+import org.openjdk.jmh.annotations.*;
+import org.openjdk.jmh.profile.StackProfiler;
+import org.openjdk.jmh.runner.Runner;
+import org.openjdk.jmh.runner.RunnerException;
+import org.openjdk.jmh.runner.options.Options;
+import org.openjdk.jmh.runner.options.OptionsBuilder;
+import org.openjdk.jmh.runner.options.TimeValue;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
+@Measurement(iterations = 10)
+@Warmup(iterations = 10)
+@BenchmarkMode(Mode.AverageTime)
+@OutputTimeUnit(TimeUnit.MICROSECONDS)
+public class AtomicExample01 {
+
+    public static void main(String[] args) throws RunnerException {
+        Options options = new OptionsBuilder()
+                .include(AtomicExample01.class.getSimpleName())
+                .forks(1)
+                .timeout(TimeValue.seconds(10))
+                .addProfiler(StackProfiler.class)
+                .build();
+        new Runner(options).run();
+    }
+
+    @GroupThreads(10)
+    @Group("sync")
+    @Benchmark
+    public void syncInc(IntMonitor monitor) {
+        monitor.synInc();
+    }
+
+    @GroupThreads(10)
+    @Group("lock")
+    @Benchmark
+    public void lockInc(IntMonitor monitor) {
+        monitor.lockInc();
+    }
+
+    @GroupThreads(10)
+    @Group("atomic")
+    @Benchmark
+    public void atomicIntegerInc(AtomicIntegerMonitor monitor) {
+        monitor.inc();
+    }
+
+    @State(Scope.Group)
+    public static class IntMonitor {
+        private final Lock lock = new ReentrantLock();
+        private int x;
+
+        public void lockInc() {
+            lock.lock();
+            try {
+                x++;
+            } finally {
+                lock.unlock();
+            }
+        }
+
+        public void synInc() {
+            synchronized (this) {
+                x++;
+            }
+        }
+    }
+
+    @State(Scope.Group)
+    public static class AtomicIntegerMonitor {
+        private final AtomicInteger x = new AtomicInteger();
+
+        public void inc() {
+            x.incrementAndGet();
+        }
+    }
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample02.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample02.java
new file mode 100644
index 0000000..291dca8
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample02.java
@@ -0,0 +1,43 @@
+package cn.bunny.atomic;
+
+import org.openjdk.jmh.annotations.*;
+import org.openjdk.jmh.runner.Runner;
+import org.openjdk.jmh.runner.RunnerException;
+import org.openjdk.jmh.runner.options.Options;
+import org.openjdk.jmh.runner.options.OptionsBuilder;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
+
+@Measurement(iterations = 10)
+@Warmup(iterations = 10)
+@BenchmarkMode(Mode.AverageTime)
+@State(Scope.Thread)
+@OutputTimeUnit(TimeUnit.MICROSECONDS)
+public class AtomicExample02 {
+
+    private AtomicInteger atomicInteger;
+
+    public static void main(String[] args) throws RunnerException {
+        Options options = new OptionsBuilder()
+                .include(AtomicExample02.class.getSimpleName())
+                .forks(1)
+                .build();
+        new Runner(options).run();
+    }
+
+    @Setup(Level.Iteration)
+    public void setup() {
+        this.atomicInteger = new AtomicInteger(0);
+    }
+
+    @Benchmark
+    public void testSet() {
+        this.atomicInteger.set(10);
+    }
+
+    @Benchmark
+    public void testLazySet() {
+        this.atomicInteger.lazySet(10);
+    }
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample04.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample04.java
new file mode 100644
index 0000000..550eab5
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample04.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample04 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample05.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample05.java
new file mode 100644
index 0000000..417928e
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample05.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample05 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample06.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample06.java
new file mode 100644
index 0000000..927743c
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample06.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample06 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample07.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample07.java
new file mode 100644
index 0000000..06862de
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample07.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample07 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample08.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample08.java
new file mode 100644
index 0000000..55c0668
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample08.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample08 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample09.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample09.java
new file mode 100644
index 0000000..baf43f0
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample09.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample09 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample10.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample10.java
new file mode 100644
index 0000000..17036e8
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample10.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample10 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample11.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample11.java
new file mode 100644
index 0000000..13e2347
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample11.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample11 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample12.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample12.java
new file mode 100644
index 0000000..400d627
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample12.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample12 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample13.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample13.java
new file mode 100644
index 0000000..38ec430
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample13.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample13 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample14.java b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample14.java
new file mode 100644
index 0000000..27d4485
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/AtomicExample14.java
@@ -0,0 +1,4 @@
+package cn.bunny.atomic;
+
+public class AtomicExample14 {
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/reference/AtomicExample03.java b/multithreading1/src/main/java/cn/bunny/atomic/reference/AtomicExample03.java
new file mode 100644
index 0000000..52c63bf
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/reference/AtomicExample03.java
@@ -0,0 +1,31 @@
+package cn.bunny.atomic.reference;
+
+import java.util.concurrent.TimeUnit;
+
+import static java.util.concurrent.ThreadLocalRandom.current;
+
+public class AtomicExample03 {
+    static volatile DebitCard debitCard = new DebitCard("Bunny", 0);
+
+    public static void main(String[] args) {
+        for (int i = 0; i < 10; i++) {
+            new Thread("B-" + i) {
+                @Override
+                public void run() {
+                    while (true) {
+                        final DebitCard dc = debitCard;
+                        DebitCard newDc = new DebitCard(dc.getAccount(), debitCard.getAmount() + 10);
+                        System.out.println(newDc);
+
+                        debitCard = newDc;
+                        try {
+                            TimeUnit.MILLISECONDS.sleep(current().nextInt(20));
+                        } catch (InterruptedException e) {
+                            e.printStackTrace();
+                        }
+                    }
+                }
+            }.start();
+        }
+    }
+}
diff --git a/multithreading1/src/main/java/cn/bunny/atomic/reference/DebitCard.java b/multithreading1/src/main/java/cn/bunny/atomic/reference/DebitCard.java
new file mode 100644
index 0000000..288518b
--- /dev/null
+++ b/multithreading1/src/main/java/cn/bunny/atomic/reference/DebitCard.java
@@ -0,0 +1,44 @@
+package cn.bunny.atomic.reference;
+
+import lombok.Getter;
+
+public class DebitCard {
+
+    @Getter
+    private final String account;
+    @Getter
+    private final int amount;
+
+    public DebitCard(String account, int amount) {
+        this.account = account;
+        this.amount = amount;
+    }
+
+    /**
+     * Returns a string representation of the object.
+     *
+     * @return a string representation of the object.
+     * @apiNote In general, the
+     * {@code toString} method returns a string that
+     * "textually represents" this object. The result should
+     * be a concise but informative representation that is easy for a
+     * person to read.
+     * It is recommended that all subclasses override this method.
+     * The string output is not necessarily stable over time or across
+     * JVM invocations.
+     * @implSpec The {@code toString} method for class {@code Object}
+     * returns a string consisting of the name of the class of which the
+     * object is an instance, the at-sign character `{@code @}', and
+     * the unsigned hexadecimal representation of the hash code of the
+     * object. In other words, this method returns a string equal to the
+     * value of:
+     * <blockquote>
+     * <pre>
+     * getClass().getName() + '@' + Integer.toHexString(hashCode())
+     * </pre></blockquote>
+     */
+    @Override
+    public String toString() {
+        return "DebitCard{" + "account='" + account + '\'' + ", amount=" + amount + '}';
+    }
+}