[rocketmq-clients] branch java updated: Adjust default thread pool core size

[aaronai]

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

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


The following commit(s) were added to refs/heads/java by this push:
     new b90b8643 Adjust default thread pool core size
b90b8643 is described below

commit b90b86434d70ac6bdfe5e05c4db85bc6fb2626d3
Author: Aaron Ai <yangkun....@gmail.com>
AuthorDate: Mon Dec 12 17:15:07 2022 +0800

    Adjust default thread pool core size
---
 .../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 4def65e5..55292619 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
@@ -150,8 +150,8 @@ public abstract class ClientImpl extends 
AbstractIdleService implements Client,
 
         final long clientIdIndex = clientId.getIndex();
         this.clientCallbackExecutor = new ThreadPoolExecutor(
-            2 * Runtime.getRuntime().availableProcessors(),
-            2 * Runtime.getRuntime().availableProcessors(),
+            Runtime.getRuntime().availableProcessors(),
+            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 4e41b7dd..99867b98 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(
-            2 * Runtime.getRuntime().availableProcessors(),
+            Runtime.getRuntime().availableProcessors(),
             new ThreadFactoryImpl("ClientScheduler", clientIndex));
 
         this.asyncWorker = new ThreadPoolExecutor(
-            2 * Runtime.getRuntime().availableProcessors(),
-            2 * Runtime.getRuntime().availableProcessors(),
+            Runtime.getRuntime().availableProcessors(),
+            Runtime.getRuntime().availableProcessors(),
             60,
             TimeUnit.SECONDS,
             new LinkedBlockingQueue<>(),