imgoby opened a new issue, #8617:
URL: https://github.com/apache/rocketmq/issues/8617
### Is Your Feature Request Related to a Problem?
If I need to create a Default MQPushConsumer, 3000 NettyRemotingClient ()
will be created by default, and each object will have an independent thread
pool: publicExecutor. Each thread pool will initialize several threads by
default. For example, if the CPU has 16 cores, a total of 3000 * 16=48000
threads will need to be created.
How to implement sharing a custom publicExecutor among these 3000
NettyRemotingClient ()
for(int i=0; i<3000;i++){
consumer = new DefaultMQPushConsumer(consumerGroup);
}
### Describe the Solution You'd Like
Support incoming thread pool
### Describe Alternatives You've Considered
for business.
### Additional Context
no
--
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]
