You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/06/15 08:28:41 UTC

[GitHub] [rocketmq] BurningCN commented on issue #4451: Question about this.lock(mq) in updateProcessQueueTableInRebalance method

BurningCN commented on issue #4451:
URL: https://github.com/apache/rocketmq/issues/4451#issuecomment-1156159863

   因为顺序消费需要判断`processQueue.isLocked()`才能往下执行，而目前只有`ConsumeMessageOrderlyService#lockMQPeriodically`触发后才能置为`processQueue.setLocked(true)`（因为初始延迟1s后触发，此时执行如上图代码的时候processQueue不会为null），这样会导致顺序消费模式会延后一段时间才开始消费(1s延迟)
   ![image](https://user-images.githubusercontent.com/43363120/173779628-64ab4436-1b09-4a9d-9f9d-99bdc66ed271.png)
   ![image](https://user-images.githubusercontent.com/43363120/173780791-5974a4d1-36d1-4607-b620-a0d4a769922d.png)
   


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org