rocketmq icon indicating copy to clipboard operation
rocketmq copied to clipboard

[Enhancement] Virtual thread support in DefaultMQPushConsumerImpl

Open He-Pin opened this issue 1 year ago • 0 comments

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()

image

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

He-Pin avatar Apr 27 '24 06:04 He-Pin