diff --git a/jcpp-infrastructure-util/src/main/java/sanbing/jcpp/infrastructure/util/config/ShardingThreadPool.java b/jcpp-infrastructure-util/src/main/java/sanbing/jcpp/infrastructure/util/config/ShardingThreadPool.java
index 8b5119c..29b6084 100644
--- a/jcpp-infrastructure-util/src/main/java/sanbing/jcpp/infrastructure/util/config/ShardingThreadPool.java
+++ b/jcpp-infrastructure-util/src/main/java/sanbing/jcpp/infrastructure/util/config/ShardingThreadPool.java
@@ -79,7 +79,7 @@ public class ShardingThreadPool {
         int partition = hash(hashFunction, hashKey);
 
         EXECUTOR_SERVICE_MAP.computeIfAbsent(partition % parallelism,
-                        p -> Executors.newFixedThreadPool(1, JCPPThreadFactory.forName("sharding-threads" + p)))
+                        p -> Executors.newFixedThreadPool(1, JCPPThreadFactory.forName("sharding-threads-%d" + p)))
                 .execute(runnable);
     }
 }
\ No newline at end of file