Fix data race

micro · Jul 12, 2024 · e945405 · e945405
1 parent 9a7cd8c
commit e945405
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/config/loader/memory/memory.go b/config/loader/memory/memory.go
@@ -40,6 +40,7 @@ type updateValue struct {
 }
 
 type watcher struct {
+	sync.Mutex
 	value   reader.Value
 	reader  reader.Reader
 	version atomic.Value
@@ -427,6 +428,9 @@ func (w *watcher) Next() (*loader.Snapshot, error) {
 }
 
 func (w *watcher) Stop() error {
+	w.Lock()
+	defer w.Unlock()
+
 	select {
 	case <-w.exit:
 	default: