optimise

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/UtilAll.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/UtilAll.java

-package org.hongxi.whatsmars.common;
+package org.hongxi.whatsmars.common.util;
 
 import lombok.extern.slf4j.Slf4j;
 

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/AtomicPositiveInteger.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/AtomicPositiveInteger.java

-package org.hongxi.whatsmars.common.util;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/ConcurrentHashSet.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/ConcurrentHashSet.java

-package org.hongxi.whatsmars.common.util;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.AbstractSet;
 import java.util.ConcurrentModificationException;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/queue/ConcurrentTreeMap.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/ConcurrentTreeMap.java

-package org.hongxi.whatsmars.common.queue;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.Comparator;
 import java.util.Map;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/CountDownLatch2.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/CountDownLatch.java

-package org.hongxi.whatsmars.common;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.AbstractQueuedSynchronizer;
@@ -6,17 +6,17 @@ import java.util.concurrent.locks.AbstractQueuedSynchronizer;
 /**
  * Add reset feature for @see java.util.concurrent.CountDownLatch
  */
-public class CountDownLatch2 {
+public class CountDownLatch {
     private final Sync sync;
 
     /**
-     * Constructs a {@code CountDownLatch2} initialized with the given count.
+     * Constructs a {@code CountDownLatch} initialized with the given count.
      *
      * @param count the number of times {@link #countDown} must be invoked before threads can pass through {@link
      * #await}
      * @throws IllegalArgumentException if {@code count} is negative
      */
-    public CountDownLatch2(int count) {
+    public CountDownLatch(int count) {
         if (count < 0) {
             throw new IllegalArgumentException("count < 0");
         }
@@ -140,7 +140,7 @@ public class CountDownLatch2 {
     }
 
     /**
-     * Synchronization control For CountDownLatch2.
+     * Synchronization control For CountDownLatch.
      * Uses AQS state to represent count.
      */
     private static final class Sync extends AbstractQueuedSynchronizer {

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/threadpool/EagerThreadPool.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/EagerThreadPool.java

-package org.hongxi.whatsmars.common.threadpool;
-
-import org.hongxi.whatsmars.common.threadlocal.NamedInternalThreadFactory;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.concurrent.Executor;
 import java.util.concurrent.ThreadPoolExecutor;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/threadpool/EagerThreadPoolExecutor.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/EagerThreadPoolExecutor.java

-package org.hongxi.whatsmars.common.threadpool;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicInteger;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/ExecutorUtils.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/ExecutorUtils.java

-package org.hongxi.whatsmars.common.util;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/threadlocal/InternalThread.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/InternalThread.java

-package org.hongxi.whatsmars.common.threadlocal;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 /**
  * InternalThread

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/threadlocal/InternalThreadLocal.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/InternalThreadLocal.java

-package org.hongxi.whatsmars.common.threadlocal;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.Collections;
 import java.util.IdentityHashMap;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/threadlocal/InternalThreadLocalMap.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/InternalThreadLocalMap.java

-package org.hongxi.whatsmars.common.threadlocal;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.Arrays;
 import java.util.concurrent.atomic.AtomicInteger;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/threadlocal/NamedInternalThreadFactory.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/NamedInternalThreadFactory.java

-package org.hongxi.whatsmars.common.threadlocal;
-
-import org.hongxi.whatsmars.common.util.NamedThreadFactory;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 /**
  * NamedInternalThreadFactory

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/NamedThreadFactory.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/NamedThreadFactory.java

-package org.hongxi.whatsmars.common.util;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.atomic.AtomicInteger;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/queue/RoundQueue.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/RoundQueue.java

-package org.hongxi.whatsmars.common.queue;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.LinkedList;
 import java.util.Queue;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/threadpool/TaskQueue.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/TaskQueue.java

-package org.hongxi.whatsmars.common.threadpool;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.RejectedExecutionException;

whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/ThreadUtils.java → whatsmars-common/src/main/java/org/hongxi/whatsmars/common/util/concurrent/ThreadUtils.java

-package org.hongxi.whatsmars.common.util;
+package org.hongxi.whatsmars.common.util.concurrent;
 
 import lombok.extern.slf4j.Slf4j;