Another implementation, the effect remains unchanged

go-kratos · May 10, 2024 · b1aa0da · b1aa0da
1 parent ae36077
commit b1aa0da
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/contrib/registry/nacos/watcher.go b/contrib/registry/nacos/watcher.go
@@ -41,14 +41,16 @@ func newWatcher(ctx context.Context, cli naming_client.INamingClient, serviceNam
 		Clusters:    clusters,
 		GroupName:   groupName,
 		SubscribeCallback: func(services []model.SubscribeService, err error) {
-			if len(w.watchChan) == 0 {
-				w.watchChan <- struct{}{}
+			select {
+			case w.watchChan <- struct{}{}:
+			default:
 			}
 		},
 	}
 	e := w.cli.Subscribe(w.subscribeParam)
-	if len(w.watchChan) == 0 {
-		w.watchChan <- struct{}{}
+	select {
+	case w.watchChan <- struct{}{}:
+	default:
 	}
 	return w, e
 }