Merge pull request kubernetes#94537 from knight42/fix/TestCacheNoConcurrentGet

test(azure): Deflake TestCacheNoConcurrentGet

Author: k8s-ci-robot

staging/src/k8s.io/legacy-cloud-providers/azure/cache/azure_cache.go

@@ -103,6 +103,15 @@ func (t *TimedCache) getInternal(key string) (*AzureCacheEntry, error) {
 	t.Lock.Lock()
 	defer t.Lock.Unlock()
 
+	// Another goroutine might have written the same key.
+	entry, exists, err = t.Store.GetByKey(key)
+	if err != nil {
+		return nil, err
+	}
+	if exists {
+		return entry.(*AzureCacheEntry), nil
+	}
+
 	// Still not found, add new entry with nil data.
 	// Note the data will be filled later by getter.
 	newEntry := &AzureCacheEntry{

staging/src/k8s.io/legacy-cloud-providers/azure/cache/azure_cache_test.go

@@ -195,8 +195,10 @@ func TestCacheNoConcurrentGet(t *testing.T) {
 	var wg sync.WaitGroup
 	for i := 0; i < 5; i++ {
 		wg.Add(1)
-		go cache.Get(key, CacheReadTypeDefault)
-		wg.Done()
+		go func() {
+			defer wg.Done()
+			_, _ = cache.Get(key, CacheReadTypeDefault)
+		}()
 	}
 	v, err := cache.Get(key, CacheReadTypeDefault)
 	wg.Wait()