You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/12/12 09:53:00 UTC
[rocketmq-clients] branch master updated: Adjust default thread pool core size
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 a26cb1a2 Adjust default thread pool core size
a26cb1a2 is described below
commit a26cb1a24acccabfe44a50ed9b5285ac23e509d3
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Mon Dec 12 17:44:59 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<>(),