From d475acb3896688096a32783d1df55dd16290c039 Mon Sep 17 00:00:00 2001
From: javahongxi <javahongxi@qq.com>
Date: Sun, 1 Sep 2019 09:34:08 +0800
Subject: [PATCH] author

---
 .../java/util/concurrent/AtomicTest.java      | 41 +++++++++++++++++++
 .../util/concurrent/DaemonThreadTest.java     |  2 +-
 .../java/util/concurrent/DeadLockTest2.java   |  2 +-
 .../concurrent/ThreadLocalRandomTest.java     | 16 ++++++++
 .../java/util/concurrent/ThreadLocalTest.java |  2 +-
 .../hongxi/whatsmars/kafka/KafkaStartup.java  |  2 +-
 6 files changed, 61 insertions(+), 4 deletions(-)
 create mode 100644 whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/AtomicTest.java
 create mode 100644 whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalRandomTest.java

diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/AtomicTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/AtomicTest.java
new file mode 100644
index 00000000..e3dcf4a9
--- /dev/null
+++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/AtomicTest.java
@@ -0,0 +1,41 @@
+package org.hongxi.java.util.concurrent;
+
+import java.util.concurrent.atomic.AtomicLong;
+
+/**
+ * @author shenhongxi 2019/09/01
+ */
+public class AtomicTest {
+
+    private static AtomicLong count = new AtomicLong();
+
+    private static Integer[] arrayOne = new Integer[] {0, 1, 2, 3, 0, 5, 6, 0, 56, 0};
+    private static Integer[] arrayTwo = new Integer[] {10, 1, 2, 3, 0, 5, 6, 0, 56, 0};
+
+    public static void main(String[] args) throws InterruptedException {
+        Thread threadOne = new Thread(() -> {
+            int size = arrayOne.length;
+            for (int i = 0; i < size; i++) {
+                if (arrayOne[i].intValue() == 0)
+                    count.incrementAndGet();
+            }
+        });
+
+        Thread threadTwo = new Thread(() -> {
+            int size = arrayTwo.length;
+            for (int i = 0; i < size; i++) {
+                if (arrayTwo[i].intValue() == 0)
+                    count.incrementAndGet();
+            }
+        });
+
+        threadOne.start();
+        threadTwo.start();
+
+        // 等待线程执行完毕
+        threadOne.join();
+        threadTwo.join();
+
+        System.out.println("count 0:" + count.get());
+    }
+}
diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DaemonThreadTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DaemonThreadTest.java
index ff8c6f0f..309f5202 100644
--- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DaemonThreadTest.java
+++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DaemonThreadTest.java
@@ -1,7 +1,7 @@
 package org.hongxi.java.util.concurrent;
 
 /**
- * Created by shenhongxi on 2019-08-31.
+ * @author shenhongxi 2019-08-31.
  */
 public class DaemonThreadTest {
 
diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DeadLockTest2.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DeadLockTest2.java
index b536cde3..75682a4f 100644
--- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DeadLockTest2.java
+++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DeadLockTest2.java
@@ -1,7 +1,7 @@
 package org.hongxi.java.util.concurrent;
 
 /**
- * Created by shenhongxi on 2019-08-31.
+ * @author shenhongxi 2019-08-31.
  */
 public class DeadLockTest2 {
 
diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalRandomTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalRandomTest.java
new file mode 100644
index 00000000..4feac4ed
--- /dev/null
+++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalRandomTest.java
@@ -0,0 +1,16 @@
+package org.hongxi.java.util.concurrent;
+
+import java.util.concurrent.ThreadLocalRandom;
+
+/**
+ * @author shenhongxi 2019-09-01
+ */
+public class ThreadLocalRandomTest {
+
+    public static void main(String[] args) {
+        ThreadLocalRandom random = ThreadLocalRandom.current();
+        for (int i = 0; i < 10; i++) {
+            System.out.println(random.nextInt(5));
+        }
+    }
+}
diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalTest.java
index 13bdb30a..edaa62ba 100644
--- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalTest.java
+++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalTest.java
@@ -1,7 +1,7 @@
 package org.hongxi.java.util.concurrent;
 
 /**
- * Created by shenhongxi on 2019-08-31.
+ * @author shenhongxi 2019-08-31.
  */
 public class ThreadLocalTest {
 
diff --git a/whatsmars-mq/whatsmars-mq-kafka-server/src/main/java/org/hongxi/whatsmars/kafka/KafkaStartup.java b/whatsmars-mq/whatsmars-mq-kafka-server/src/main/java/org/hongxi/whatsmars/kafka/KafkaStartup.java
index 1af15be9..b74ff1a8 100644
--- a/whatsmars-mq/whatsmars-mq-kafka-server/src/main/java/org/hongxi/whatsmars/kafka/KafkaStartup.java
+++ b/whatsmars-mq/whatsmars-mq-kafka-server/src/main/java/org/hongxi/whatsmars/kafka/KafkaStartup.java
@@ -3,7 +3,7 @@ package org.hongxi.whatsmars.kafka;
 import kafka.Kafka;
 
 /**
- * Created by shenhongxi on 2019-08-27.
+ * @author shenhongxi 2019-08-27.
  */
 public class KafkaStartup {
 
-- 
GitLab