Nov 18, 2025 · Nov 18, 2025 · Nov 18, 2025 · Nov 18, 2025
diff --git a/framework/src/Volo.Abp.Caching/Volo/Abp/Caching/DistributedCache.cs b/framework/src/Volo.Abp.Caching/Volo/Abp/Caching/DistributedCache.cs
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using AsyncKeyedLock;
 using Microsoft.Extensions.Caching.Distributed;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;

    protected IUnitOfWorkManager UnitOfWorkManager { get; }

    protectedSemaphoreSlim SyncSemaphore { get; }
    protectedAsyncKeyedLocker<string> Locker { get; }

    protected DistributedCacheEntryOptions DefaultCacheOptions = default!;

        ServiceScopeFactory = serviceScopeFactory;
        UnitOfWorkManager = unitOfWorkManager;

 SyncSemaphore = new SemaphoreSlim(1, 1);
 Locker = new();

        SetDefaultOptions();
    }
            return value;
        }

        using (SyncSemaphore.Lock())
        using (Locker.Lock(NormalizeKey(key)))
        {
            value = Get(key, hideErrors, considerUow);
            if (value != null)
            return value;
        }

        using (awaitSyncSemaphore.LockAsync(token))
        using (awaitLocker.LockAsync(NormalizeKey(key),token))
        {
            value = await GetAsync(key, hideErrors, considerUow, token);
            if (value != null)
Original file line number	Diff line number	Diff line change
Expand Up		@@ -3,6 +3,7 @@
		using System.Linq;
		using System.Threading;
		using System.Threading.Tasks;
		using AsyncKeyedLock;
		using Microsoft.Extensions.Caching.Distributed;
		using Microsoft.Extensions.DependencyInjection;
		using Microsoft.Extensions.Logging;
Expand DownExpand Up		@@ -162,7 +163,7 @@ public class DistributedCache<TCacheItem, TCacheKey> : IDistributedCache<TCacheI

		protected IUnitOfWorkManager UnitOfWorkManager { get; }

		protectedSemaphoreSlim SyncSemaphore { get; }
		protectedAsyncKeyedLocker<string> Locker { get; }

		protected DistributedCacheEntryOptions DefaultCacheOptions = default!;

Expand All		@@ -186,7 +187,7 @@ public DistributedCache(
		ServiceScopeFactory = serviceScopeFactory;
		UnitOfWorkManager = unitOfWorkManager;

		SyncSemaphore = new SemaphoreSlim(1, 1);
		Locker = new();

		SetDefaultOptions();
		}
Expand DownExpand Up		@@ -534,7 +535,7 @@ await GetAsync(key, false, considerUow, token: token))
		return value;
		}

		using (SyncSemaphore.Lock())
		using (Locker.Lock(NormalizeKey(key)))
		{
		value = Get(key, hideErrors, considerUow);
		if (value != null)
Expand DownExpand Up		@@ -589,7 +590,7 @@ await GetAsync(key, false, considerUow, token: token))
		return value;
		}

		using (awaitSyncSemaphore.LockAsync(token))
		using (awaitLocker.LockAsync(NormalizeKey(key),token))
		{
		value = await GetAsync(key, hideErrors, considerUow, token);
		if (value != null)
Expand Down