RocketMQ原理解析-consumer 5.push消費-順序消費消息

順序消費服務ConsumeMessageConcurrentlyService構建的時候線程                    構建一個線程池來接收消費請求ConsumeRequest對象                    構建一個單線程的本地線程,用來稍後定時從新消費ConsumeRequest, 用來執行定時週期性(一秒)鍾鎖隊列任務blog            週期性鎖隊列lock
相關文章
相關標籤/搜索