author

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/AtomicTest.java

+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());
+    }
+}

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DaemonThreadTest.java

 package org.hongxi.java.util.concurrent;
 
 /**
- * Created by shenhongxi on 2019-08-31.
+ * @author shenhongxi 2019-08-31.
  */
 public class DaemonThreadTest {
 

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/DeadLockTest2.java

 package org.hongxi.java.util.concurrent;
 
 /**
- * Created by shenhongxi on 2019-08-31.
+ * @author shenhongxi 2019-08-31.
  */
 public class DeadLockTest2 {
 

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalRandomTest.java

+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));
+        }
+    }
+}

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ThreadLocalTest.java

 package org.hongxi.java.util.concurrent;
 
 /**
- * Created by shenhongxi on 2019-08-31.
+ * @author shenhongxi 2019-08-31.
  */
 public class ThreadLocalTest {
 

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 {