From da795ee8c0f87990b069a63446f3e23e73af1fe5 Mon Sep 17 00:00:00 2001 From: Aaron Ai Date: Sat, 24 Sep 2022 10:41:41 +0800 Subject: [PATCH] Java: Adjust default thread num of threadpool --- .../org/apache/rocketmq/client/java/impl/ClientImpl.java | 4 ++-- .../apache/rocketmq/client/java/impl/ClientManagerImpl.java | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java index 0d2944265..d9cbdbcf3 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java @@ -149,8 +149,8 @@ public ClientImpl(ClientConfiguration clientConfiguration, Set topics) { final long clientIdIndex = clientId.getIndex(); this.clientCallbackExecutor = new ThreadPoolExecutor( - Runtime.getRuntime().availableProcessors(), - Runtime.getRuntime().availableProcessors(), + 2 * Runtime.getRuntime().availableProcessors(), + 2 * Runtime.getRuntime().availableProcessors(), 60, TimeUnit.SECONDS, new LinkedBlockingQueue<>(), diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java index 816183a04..d90be989e 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java @@ -113,12 +113,12 @@ public ClientManagerImpl(Client client) { this.rpcClientTableLock = new ReentrantReadWriteLock(); final long clientIndex = client.getClientId().getIndex(); this.scheduler = new ScheduledThreadPoolExecutor( - Runtime.getRuntime().availableProcessors(), + 2 * Runtime.getRuntime().availableProcessors(), new ThreadFactoryImpl("ClientScheduler", clientIndex)); this.asyncWorker = new ThreadPoolExecutor( - Runtime.getRuntime().availableProcessors(), - Runtime.getRuntime().availableProcessors(), + 2 * Runtime.getRuntime().availableProcessors(), + 2 * Runtime.getRuntime().availableProcessors(), 60, TimeUnit.SECONDS, new LinkedBlockingQueue<>(),