chenchengwangS opened a new issue, #1010:
URL: https://github.com/apache/rocketmq-clients/issues/1010
### Programming Language of the Client
Java
### Is Your Feature Request Related to a Problem?
` public PushConsumerImpl(ClientConfiguration clientConfiguration, String
consumerGroup,
Map<String, FilterExpression> subscriptionExpressions,
MessageListener messageListener,
int maxCacheMessageCount, int maxCacheMessageSizeInBytes, int
consumptionThreadCount) {
super(clientConfiguration, consumerGroup,
subscriptionExpressions.keySet());
this.clientConfiguration = clientConfiguration;
Resource groupResource = new
Resource(clientConfiguration.getNamespace(), consumerGroup);
this.pushSubscriptionSettings = new
PushSubscriptionSettings(clientConfiguration.getNamespace(), clientId,
endpoints, groupResource,
clientConfiguration.getRequestTimeout(), subscriptionExpressions);
this.consumerGroup = consumerGroup;
this.subscriptionExpressions = subscriptionExpressions;
this.cacheAssignments = new ConcurrentHashMap<>();
this.messageListener = messageListener;
this.maxCacheMessageCount = maxCacheMessageCount;
this.maxCacheMessageSizeInBytes = maxCacheMessageSizeInBytes;
this.receptionTimes = new AtomicLong(0);
this.receivedMessagesQuantity = new AtomicLong(0);
this.consumptionOkQuantity = new AtomicLong(0);
this.consumptionErrorQuantity = new AtomicLong(0);
this.processQueueTable = new ConcurrentHashMap<>();
this.consumptionExecutor = new ThreadPoolExecutor(
consumptionThreadCount,
consumptionThreadCount,
60,
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(),
new ThreadFactoryImpl("MessageConsumption",
this.getClientId().getIndex()));
}`
为什么每个消费者的每个topic都会创建一个线程池？这样设计的初衷是为了什么？求大佬解惑
### Describe the Solution You'd Like
无
### Describe Alternatives You've Considered
无
### Additional Context
_No response_
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
