config listen execute max chan (#403)

nacos-group · Feb 12, 2022 · d91ced4 · d91ced4
1 parent 494f91e
commit d91ced4
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/clients/config_client/config_client.go b/clients/config_client/config_client.go
@@ -19,6 +19,7 @@ package config_client
 import (
 	"errors"
 	"fmt"
+	"math"
 	"os"
 	"strings"
 	"sync"
@@ -116,8 +117,8 @@ func NewConfigClient(nc nacos_client.INacosClient) (*ConfigClient, error) {
 	config.uid = uid.String()
 
 	config.cacheMap = cache.NewConcurrentMap()
-
-	config.listenExecute = make(chan struct{}, 1)
+	// maximum buffered queue to prevent chan deadlocks during frequent configuration file updates
+	config.listenExecute = make(chan struct{}, math.MaxInt64)
 
 	config.startInternal()