[ISSUE #1279]⚡️Optimize name server DefaultRequestProcessor#get_all_topic_list_from_nameserver (#1280)

mxsm · web-flow · commit 4ed0d3cc63e6 · 2024-11-24T22:28:53.000+08:00
diff --git a/rocketmq-namesrv/src/route/route_info_manager.rs b/rocketmq-namesrv/src/route/route_info_manager.rs
@@ -721,12 +721,13 @@ impl RouteInfoManager {
     }
 
     pub(crate) fn get_all_topic_list(&self) -> TopicList {
+        let lock = self.lock.read();
         let topics = self
             .topic_queue_table
             .keys()
             .cloned()
             .collect::<Vec<CheetahString>>();
-
+        drop(lock);
         TopicList {
             topic_list: topics,
             broker_addr: None,
