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/09/24 02:47:15 UTC
[rocketmq-clients] branch master updated: Java: Adjust default thread num of threadpool (#247)
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 <ya...@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<>(),