[rocketmq-clients] branch master updated: Java: Adjust default thread num of threadpool (#247)

[aaronai]

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

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new afc6c40  Java: Adjust default thread num of threadpool (#247)
afc6c40 is described below

commit afc6c40960cb5112e644ef79dab16473c99ac753
Author: Aaron Ai <yangkun....@gmail.com>
AuthorDate: Sat Sep 24 10:47:10 2022 +0800

    Java: Adjust default thread num of threadpool (#247)
---
 .../main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java  | 4 ++--
 .../org/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 0d29442..d9cbdbc 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 abstract class ClientImpl extends 
AbstractIdleService implements Client,
 
         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 816183a..d90be98 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 class ClientManagerImpl extends ClientManager {
         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<>(),