fix：block under multiple listeners to re-listen nacos-group#300 nacos…

…-group#306 nacos-group#307
Memoyu · Aug 10, 2024 · 8ac9b6b · 8ac9b6b
1 parent e6cf34b
commit 8ac9b6b
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/src/Nacos/V2/Config/Impl/ConfigRpcTransportClient.cs b/src/Nacos/V2/Config/Impl/ConfigRpcTransportClient.cs
@@ -454,7 +454,7 @@ protected async override Task ExecuteConfigListen()
             }
 
             if (hasChangedKeys)
-               await NotifyListenConfig().ConfigureAwait(false);
+                await NotifyListenConfig().ConfigureAwait(false);
         }
 
         private async Task RefreshContentAndCheck(string groupKey, bool notify)
@@ -501,8 +501,13 @@ private void RemoveCache(string dataId, string group, string tenant)
 
         protected override Task NotifyListenConfig()
         {
-            _listenExecutebell.Add(_bellItem);
-            return Task.CompletedTask;
+            return Task.Factory.StartNew(async () =>
+            {
+                while (!_listenExecutebell.TryAdd(_bellItem))
+                {
+                    await Task.Delay(500).ConfigureAwait(false);
+                }
+            });
         }
     }
 }