[GitHub] [rocketmq] liyiwen3 opened a new issue #1610: Is it neccessary that use lock per message queue where orderly comsuming?

Sun, 24 Nov 2019 18:38:24 -0800 

liyiwen3 opened a new issue #1610: Is it neccessary that use lock per message 
queue where orderly comsuming?
URL: https://github.com/apache/rocketmq/issues/1610
 
 
   Is it neccessary that use lock per message queue where orderly comsuming?
   
   顺序消费的时候，为每个消息队列分配一把锁，这个是有必要的吗？
    final Object objLock = messageQueueLock.fetchLockObject(this.messageQueue);
               synchronized (objLock) {
   在ConsumeMessageOrderlyService的420和421行，对同一个队列的消息的拉取本身是串行的了，
   且由于ProcessQueue的consuming状态位的存在，对同一个队列的消费已经可以保证是串行了，
   所以在消费的时候，为每个消息队列分配一把锁，这个是有必要的吗？

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to