添加thread name space

mpusher · Jan 18, 2016 · 9ab542f · 9ab542f
1 parent b66b00d
commit 9ab542f
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 3 deletions.
diff --git a/mpush-common/src/main/java/com/shinemo/mpush/common/AbstractServer.java b/mpush-common/src/main/java/com/shinemo/mpush/common/AbstractServer.java
@@ -13,6 +13,7 @@
 import com.shinemo.mpush.tools.config.ConfigCenter;
 import com.shinemo.mpush.tools.redis.RedisGroup;
 import com.shinemo.mpush.tools.spi.ServiceContainer;
+import com.shinemo.mpush.tools.thread.ThreadNameSpace;
 import com.shinemo.mpush.tools.thread.ThreadPoolUtil;
 import com.shinemo.mpush.tools.zk.ZKPath;
 import com.shinemo.mpush.tools.zk.ZkRegister;
@@ -104,7 +105,7 @@ public void onFailure(String message) {
                     }
                 });
             }
-        }, "conn-server", false).start();
+        }, ThreadNameSpace.getServerName(server.getClass().getSimpleName()), false).start();
 
 	}
 

diff --git a/mpush-tools/src/main/java/com/shinemo/mpush/tools/thread/ThreadNameSpace.java b/mpush-tools/src/main/java/com/shinemo/mpush/tools/thread/ThreadNameSpace.java
@@ -20,5 +20,17 @@ public class ThreadNameSpace {
     public static final String getUniqueName(String serviceName) {
         return "mp-sn-" + serviceName;
     }
+
+    public static final String THREAD_NAME_PREFIX = "mp-t-";
 
+    public static final String getServerName(String serverName){
+    	if(serverName.equals("ConnectionServer")){
+        	return "mp-start-cs";
+    	}else if(serverName.equals("GatewayServer")){
+        	return "mp-start-gs";
+    	}else{
+        	return "mp-start-unknow";
+    	}
+    }
+
 }
diff --git a/mpush-tools/src/main/java/com/shinemo/mpush/tools/thread/ThreadPoolUtil.java b/mpush-tools/src/main/java/com/shinemo/mpush/tools/thread/ThreadPoolUtil.java
@@ -6,7 +6,7 @@
 
 
 public class ThreadPoolUtil {
-    public static final String THREAD_NAME_PREFIX = "mp-t-";
+
     private static final ThreadPoolManager threadPoolManager =
             new ThreadPoolManager(Constants.MIN_POOL_SIZE, Constants.MAX_POOL_SIZE, Constants.THREAD_QUEUE_SIZE);
 
@@ -31,7 +31,7 @@ public static Executor getWorkExecutor() {
     public static Thread newThread(Runnable r, String name, boolean daemon) {
         Thread t = new Thread(r);
         t.setDaemon(daemon);
-        t.setName(THREAD_NAME_PREFIX + name);
+        t.setName(ThreadNameSpace.THREAD_NAME_PREFIX + name);
         return t;
     }