fix: lru lock (#2613)

* fix: lru lock * fix: lru lock * fix: lru lock
openimsdk · Sep 12, 2024 · b13c337 · b13c337
1 parent 80c71b7
commit b13c337
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/pkg/localcache/lru/lru_lazy.go b/pkg/localcache/lru/lru_lazy.go
@@ -100,12 +100,12 @@ func (x *LayLRU[K, V]) GetBatch(keys []K, fetch func(keys []K) (map[K]V, error))
 	setVs := make(map[K]*layLruItem[V])
 	for _, key := range keys {
 		v, ok := x.core.Get(key)
+		x.lock.Unlock()
 		if ok {
-			x.lock.Unlock()
 			v.lock.Lock()
 			expires, value, err1 := v.expires, v.value, v.err
+			v.lock.Unlock()
 			if expires != 0 && expires > time.Now().UnixMilli() {
-				v.lock.Unlock()
 				x.target.IncrGetHit()
 				res[key] = value
 				if err1 != nil {
@@ -117,7 +117,6 @@ func (x *LayLRU[K, V]) GetBatch(keys []K, fetch func(keys []K) (map[K]V, error))
 			}
 		}
 		queries = append(queries, key)
-		x.lock.Unlock()
 	}
 	values, err1 := fetch(queries)
 	if err1 != nil {