diff --git a/jraft-core/pom.xml b/jraft-core/pom.xml index dc869d6e9..4fa739f4b 100644 --- a/jraft-core/pom.xml +++ b/jraft-core/pom.xml @@ -5,7 +5,7 @@ jraft-parent com.alipay.sofa - 1.3.13 + 1.3.14 jraft-core jar diff --git a/jraft-core/src/main/java/com/alipay/sofa/jraft/rpc/RpcUtils.java b/jraft-core/src/main/java/com/alipay/sofa/jraft/rpc/RpcUtils.java index 38a421a0f..ad0f1ebea 100644 --- a/jraft-core/src/main/java/com/alipay/sofa/jraft/rpc/RpcUtils.java +++ b/jraft-core/src/main/java/com/alipay/sofa/jraft/rpc/RpcUtils.java @@ -38,40 +38,44 @@ */ public final class RpcUtils { - private static final Logger LOG = LoggerFactory.getLogger(RpcUtils.class); + private static final Logger LOG = LoggerFactory + .getLogger(RpcUtils.class); /** * Default jraft closure executor pool minimum size, CPUs by default. */ - public static final int MIN_RPC_CLOSURE_EXECUTOR_POOL_SIZE = SystemPropertyUtil.getInt( - "jraft.rpc.closure.threadpool.size.min", - Utils.cpus()); + public static final int MIN_RPC_CLOSURE_EXECUTOR_POOL_SIZE = SystemPropertyUtil + .getInt( + "jraft.rpc.closure.threadpool.size.min", + Utils.cpus()); /** * Default jraft closure executor pool maximum size. */ - public static final int MAX_RPC_CLOSURE_EXECUTOR_POOL_SIZE = SystemPropertyUtil.getInt( - "jraft.rpc.closure.threadpool.size.max", - Math.max(100, Utils.cpus() * 5)); + public static final int MAX_RPC_CLOSURE_EXECUTOR_POOL_SIZE = SystemPropertyUtil + .getInt( + "jraft.rpc.closure.threadpool.size.max", + Math.max(100, Utils.cpus() * 5)); /** * Global thread pool to run rpc closure. */ - private static ThreadPoolExecutor RPC_CLOSURE_EXECUTOR = ThreadPoolUtil - .newBuilder() - .poolName("JRAFT_RPC_CLOSURE_EXECUTOR") - .enableMetric(true) - .coreThreads( - MIN_RPC_CLOSURE_EXECUTOR_POOL_SIZE) - .maximumThreads( - MAX_RPC_CLOSURE_EXECUTOR_POOL_SIZE) - .keepAliveSeconds(60L) - .workQueue(new SynchronousQueue<>()) - .threadFactory( - new NamedThreadFactory( - "JRaft-Rpc-Closure-Executor-", - true)) // - .build(); + private static final ThreadPoolExecutor RPC_CLOSURE_EXECUTOR = ThreadPoolUtil + .newBuilder() + .poolName( + "JRAFT_RPC_CLOSURE_EXECUTOR") + .enableMetric(true) + .coreThreads( + MIN_RPC_CLOSURE_EXECUTOR_POOL_SIZE) + .maximumThreads( + MAX_RPC_CLOSURE_EXECUTOR_POOL_SIZE) + .keepAliveSeconds(60L) + .workQueue(new SynchronousQueue<>()) + .threadFactory( + new NamedThreadFactory( + "JRaft-Rpc-Closure-Executor-", + true)) // + .build(); /** * Run closure with OK status in thread pool. diff --git a/jraft-example/pom.xml b/jraft-example/pom.xml index 879f222c8..051bc93d9 100644 --- a/jraft-example/pom.xml +++ b/jraft-example/pom.xml @@ -5,7 +5,7 @@ jraft-parent com.alipay.sofa - 1.3.13 + 1.3.14 jraft-example jar diff --git a/jraft-extension/bdb-log-storage-impl/pom.xml b/jraft-extension/bdb-log-storage-impl/pom.xml index be28e0389..7d6680efc 100644 --- a/jraft-extension/bdb-log-storage-impl/pom.xml +++ b/jraft-extension/bdb-log-storage-impl/pom.xml @@ -4,7 +4,7 @@ jraft-extension com.alipay.sofa - 1.3.13 + 1.3.14 bdb-log-storage-impl bdb-log-storage-impl ${project.version} diff --git a/jraft-extension/java-log-storage-impl/pom.xml b/jraft-extension/java-log-storage-impl/pom.xml index 9ec35f6ae..2ed9b628d 100644 --- a/jraft-extension/java-log-storage-impl/pom.xml +++ b/jraft-extension/java-log-storage-impl/pom.xml @@ -4,7 +4,7 @@ jraft-extension com.alipay.sofa - 1.3.13 + 1.3.14 java-log-storage-impl diff --git a/jraft-extension/pom.xml b/jraft-extension/pom.xml index 69ce2d422..1a016ce0f 100644 --- a/jraft-extension/pom.xml +++ b/jraft-extension/pom.xml @@ -4,7 +4,7 @@ jraft-parent com.alipay.sofa - 1.3.13 + 1.3.14 jraft-extension diff --git a/jraft-extension/rpc-grpc-impl/pom.xml b/jraft-extension/rpc-grpc-impl/pom.xml index 3719331e5..1d3e1e978 100644 --- a/jraft-extension/rpc-grpc-impl/pom.xml +++ b/jraft-extension/rpc-grpc-impl/pom.xml @@ -4,7 +4,7 @@ jraft-extension com.alipay.sofa - 1.3.13 + 1.3.14 rpc-grpc-impl diff --git a/jraft-rheakv/pom.xml b/jraft-rheakv/pom.xml index 9fac8cc96..db55b2730 100644 --- a/jraft-rheakv/pom.xml +++ b/jraft-rheakv/pom.xml @@ -4,7 +4,7 @@ jraft-parent com.alipay.sofa - 1.3.13 + 1.3.14 jraft-rheakv diff --git a/jraft-rheakv/rheakv-core/pom.xml b/jraft-rheakv/rheakv-core/pom.xml index 5b8db59c1..8e3720d38 100644 --- a/jraft-rheakv/rheakv-core/pom.xml +++ b/jraft-rheakv/rheakv-core/pom.xml @@ -4,7 +4,7 @@ jraft-rheakv com.alipay.sofa - 1.3.13 + 1.3.14 jraft-rheakv-core diff --git a/jraft-rheakv/rheakv-pd/pom.xml b/jraft-rheakv/rheakv-pd/pom.xml index 8279d69c6..e9c4b67e9 100644 --- a/jraft-rheakv/rheakv-pd/pom.xml +++ b/jraft-rheakv/rheakv-pd/pom.xml @@ -4,7 +4,7 @@ jraft-rheakv com.alipay.sofa - 1.3.13 + 1.3.14 jraft-rheakv-pd diff --git a/jraft-test/pom.xml b/jraft-test/pom.xml index 4e8ebdcdd..e3d460278 100644 --- a/jraft-test/pom.xml +++ b/jraft-test/pom.xml @@ -5,7 +5,7 @@ jraft-parent com.alipay.sofa - 1.3.13 + 1.3.14 jraft-test jar diff --git a/pom.xml b/pom.xml index 90aa1cd84..8fd58064d 100644 --- a/pom.xml +++ b/pom.xml @@ -4,7 +4,7 @@ com.alipay.sofa jraft-parent - 1.3.13 + 1.3.14 pom ${project.groupId}:${project.artifactId}