diff --git a/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java b/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java
index 901a464a..433ae39a 100644
--- a/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java
+++ b/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java
@@ -21,8 +21,8 @@ import com.zfoo.net.core.tcp.TcpServer;
 import com.zfoo.net.session.model.AttributeType;
 import com.zfoo.net.util.SessionUtils;
 import com.zfoo.protocol.collection.ArrayUtils;
-import com.zfoo.protocol.collection.ConcurrentArrayList;
-import com.zfoo.protocol.collection.ConcurrentHashSet;
+import com.zfoo.protocol.collection.concurrent.ConcurrentArrayList;
+import com.zfoo.protocol.collection.concurrent.ConcurrentHashSet;
 import com.zfoo.protocol.exception.ExceptionUtils;
 import com.zfoo.protocol.util.AssertionUtils;
 import com.zfoo.protocol.util.IOUtils;
diff --git a/protocol/src/main/java/com/zfoo/protocol/collection/ConcurrentArrayList.java b/protocol/src/main/java/com/zfoo/protocol/collection/concurrent/ConcurrentArrayList.java
similarity index 99%
rename from protocol/src/main/java/com/zfoo/protocol/collection/ConcurrentArrayList.java
rename to protocol/src/main/java/com/zfoo/protocol/collection/concurrent/ConcurrentArrayList.java
index 63c13d26..3fec3c7e 100644
--- a/protocol/src/main/java/com/zfoo/protocol/collection/ConcurrentArrayList.java
+++ b/protocol/src/main/java/com/zfoo/protocol/collection/concurrent/ConcurrentArrayList.java
@@ -10,7 +10,7 @@
  * See the License for the specific language governing permissions and limitations under the License.
  */
 
-package com.zfoo.protocol.collection;
+package com.zfoo.protocol.collection.concurrent;
 
 import java.util.*;
 import java.util.concurrent.locks.ReentrantLock;
diff --git a/protocol/src/main/java/com/zfoo/protocol/collection/ConcurrentHashSet.java b/protocol/src/main/java/com/zfoo/protocol/collection/concurrent/ConcurrentHashSet.java
similarity index 97%
rename from protocol/src/main/java/com/zfoo/protocol/collection/ConcurrentHashSet.java
rename to protocol/src/main/java/com/zfoo/protocol/collection/concurrent/ConcurrentHashSet.java
index 793619aa..f4a61deb 100644
--- a/protocol/src/main/java/com/zfoo/protocol/collection/ConcurrentHashSet.java
+++ b/protocol/src/main/java/com/zfoo/protocol/collection/concurrent/ConcurrentHashSet.java
@@ -10,7 +10,7 @@
  * See the License for the specific language governing permissions and limitations under the License.
  */
 
-package com.zfoo.protocol.collection;
+package com.zfoo.protocol.collection.concurrent;
 
 import java.util.AbstractSet;
 import java.util.Iterator;