ChenYilei2016 opened a new issue, #621:
URL: https://github.com/apache/rocketmq-clients/issues/621
### Programming Language of the Client
Java
### Is Your Feature Request Related to a Problem?
final ClientServiceProvider provider = ClientServiceProvider.loadService();
provider.newPushConsumerBuilder().setMessageListener(xxxx).build();
**Each time the build method is executed, multiple thread pools are created
internally** :
org.apache.rocketmq.client.java.impl.consumer.PushConsumerImpl#consumptionExecutor
org.apache.rocketmq.client.java.impl.ClientImpl#clientCallbackExecutor
org.apache.rocketmq.client.java.impl.ClientImpl#telemetryCommandExecutor
org.apache.rocketmq.client.java.impl.ClientImpl#clientManager
- org.apache.rocketmq.client.java.impl.ClientManagerImpl#scheduler
- org.apache.rocketmq.client.java.impl.ClientManagerImpl#asyncWorker
When the project subscribes to more topic, a large number of threads will be
created and remain in the application all the time.
### Describe the Solution You'd Like
I suggest that the thread pool created be changed to one similar to tomcat ,
or call java.util.concurrent.ThreadPoolExecutor#allowCoreThreadTimeOut
### 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: commits-unsubscr...@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
