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());
}
/**