rocketmq
rocketmq copied to clipboard
[Enhancement] Virtual thread support in DefaultMQPushConsumerImpl
Before Creating the Enhancement Request
- [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature.
Summary
The current DefaultMQPushConsumerImpl will pin the Carrier thread when start() and shutdown()
Motivation
Better Virtual thread support
Describe the Solution You'd Like
Make use of ReentrantLock instead
Describe Alternatives You've Considered
do nothing
Additional Context
No response