This is an automated email from the ASF dual-hosted git repository.

lta pushed a commit to branch cluster_concurrent
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/cluster_concurrent by this 
push:
     new 59c44f4  rename ThreadName to ClusterThreadName
59c44f4 is described below

commit 59c44f4fb00a9b17b9338f2a013105c2a836fba6
Author: lta <[email protected]>
AuthorDate: Thu Apr 11 16:41:52 2019 +0800

    rename ThreadName to ClusterThreadName
---
 .../cluster/concurrent/{ThreadName.java => ClusterThreadName.java}    | 4 ++--
 .../java/org/apache/iotdb/cluster/concurrent/pool/QPTaskManager.java  | 4 ++--
 .../org/apache/iotdb/cluster/concurrent/pool/RaftTaskManager.java     | 4 ++--
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/ThreadName.java 
b/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/ClusterThreadName.java
similarity index 93%
rename from 
cluster/src/main/java/org/apache/iotdb/cluster/concurrent/ThreadName.java
rename to 
cluster/src/main/java/org/apache/iotdb/cluster/concurrent/ClusterThreadName.java
index b500c18..c071916 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/ThreadName.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/ClusterThreadName.java
@@ -18,13 +18,13 @@
  */
 package org.apache.iotdb.cluster.concurrent;
 
-public enum ThreadName {
+public enum ClusterThreadName {
   QP_TASK("QP-Task-Thread"),
   RAFT_TASK("Raft-Task-Thread");
 
   private String name;
 
-  ThreadName(String name) {
+  ClusterThreadName(String name) {
     this.name = name;
   }
 
diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/QPTaskManager.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/QPTaskManager.java
index 8ea8a5f..5bb51ac 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/QPTaskManager.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/QPTaskManager.java
@@ -18,7 +18,7 @@
  */
 package org.apache.iotdb.cluster.concurrent.pool;
 
-import org.apache.iotdb.cluster.concurrent.ThreadName;
+import org.apache.iotdb.cluster.concurrent.ClusterThreadName;
 import org.apache.iotdb.cluster.config.ClusterConfig;
 import org.apache.iotdb.cluster.config.ClusterDescriptor;
 import org.apache.iotdb.db.concurrent.IoTDBThreadPoolFactory;
@@ -43,7 +43,7 @@ public class QPTaskManager extends ThreadPoolManager {
 
     ClusterConfig config = ClusterDescriptor.getInstance().getConfig();
     this.threadCnt = config.getConcurrentQPSubTaskThread();
-    pool = IoTDBThreadPoolFactory.newFixedThreadPool(threadCnt, 
ThreadName.QP_TASK.getName());
+    pool = IoTDBThreadPoolFactory.newFixedThreadPool(threadCnt, 
ClusterThreadName.QP_TASK.getName());
   }
 
   /**
diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/RaftTaskManager.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/RaftTaskManager.java
index ea60b76..4fdcc46 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/RaftTaskManager.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/concurrent/pool/RaftTaskManager.java
@@ -18,7 +18,7 @@
  */
 package org.apache.iotdb.cluster.concurrent.pool;
 
-import org.apache.iotdb.cluster.concurrent.ThreadName;
+import org.apache.iotdb.cluster.concurrent.ClusterThreadName;
 import org.apache.iotdb.cluster.config.ClusterConfig;
 import org.apache.iotdb.cluster.config.ClusterDescriptor;
 import org.apache.iotdb.db.concurrent.IoTDBThreadPoolFactory;
@@ -42,7 +42,7 @@ public class RaftTaskManager extends ThreadPoolManager{
   public void init() {
     ClusterConfig config = ClusterDescriptor.getInstance().getConfig();
     int threadCnt = config.getConcurrentQPSubTaskThread();
-    pool = IoTDBThreadPoolFactory.newFixedThreadPool(threadCnt, 
ThreadName.QP_TASK.getName());
+    pool = IoTDBThreadPoolFactory.newFixedThreadPool(threadCnt, 
ClusterThreadName.QP_TASK.getName());
   }
 
   /**

Reply via email to