opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-29 04:13:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #10462] Optimize thread pool sizes for commit and fetch executors (#10472)

Browse Source
This commit is contained in:
lizhimins
2026-06-11 19:21:09 +08:00
committed by GitHub
parent 68cc743881
commit 84fc240acc
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/MessageStoreExecutor.java
+8 -7
View File
@@ -48,31 +48,32 @@ public class MessageStoreExecutor {
}
public MessageStoreExecutor(int maxQueueCapacity) {
int processors = Runtime.getRuntime().availableProcessors();
this.commonExecutor = ThreadUtils.newScheduledThreadPool(
Math.max(4, Runtime.getRuntime().availableProcessors()),
Math.max(4, processors),
new ThreadFactoryImpl("TieredCommonExecutor_"));
this.bufferCommitThreadPoolQueue = new LinkedBlockingQueue<>(maxQueueCapacity);
this.bufferCommitExecutor = ThreadUtils.newThreadPoolExecutor(
Math.max(16, Runtime.getRuntime().availableProcessors() * 4),
Math.max(16, Runtime.getRuntime().availableProcessors() * 4),
Math.max(4, processors),
Math.max(16, processors * 2),
TimeUnit.MINUTES.toMillis(1), TimeUnit.MILLISECONDS,
this.bufferCommitThreadPoolQueue,
new ThreadFactoryImpl("BufferCommitExecutor_"));
this.bufferFetchThreadPoolQueue = new LinkedBlockingQueue<>(maxQueueCapacity);
this.bufferFetchExecutor = ThreadUtils.newThreadPoolExecutor(
Math.max(16, Runtime.getRuntime().availableProcessors() * 4),
Math.max(16, Runtime.getRuntime().availableProcessors() * 4),
Math.max(4, processors),
Math.max(16, processors * 2),
TimeUnit.MINUTES.toMillis(1), TimeUnit.MILLISECONDS,
this.bufferFetchThreadPoolQueue,
new ThreadFactoryImpl("BufferFetchExecutor_"));
this.fileRecyclingThreadPoolQueue = new LinkedBlockingQueue<>(maxQueueCapacity);
this.fileRecyclingExecutor = ThreadUtils.newThreadPoolExecutor(
Math.max(4, Runtime.getRuntime().availableProcessors()),
Math.max(4, Runtime.getRuntime().availableProcessors()),
Math.max(4, processors),
Math.max(4, processors),
TimeUnit.MINUTES.toMillis(1), TimeUnit.MILLISECONDS,
this.fileRecyclingThreadPoolQueue,
new ThreadFactoryImpl("BufferFetchExecutor_"));