[ISSUE #1279]⚡️Optimize name server DefaultRequestProcessor#get_all_t…

…opic_list_from_nameserver (#1280)
mxsm · Nov 24, 2024 · 4ed0d3c · 4ed0d3c
1 parent a40e982
commit 4ed0d3c
Showing 1 changed file with 2 additions and 1 deletion.
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,