Merge pull request #16 from PandaTechAM/development

minor optimization in lock service

Author: HaikAsatryan

src/DistributedCache/DistributedCache.csproj

@@ -8,13 +8,13 @@
         <PackageReadmeFile>Readme.md</PackageReadmeFile>
         <Authors>Pandatech</Authors>
         <Copyright>MIT</Copyright>
-        <Version>4.0.6</Version>
+        <Version>4.0.7</Version>
         <PackageId>Pandatech.DistributedCache</PackageId>
         <Title>Pandatech Distributed Cache</Title>
         <PackageTags>pandatech;cache;hybrid-cache;distributed-cahce;message-pack;rate-limiting;redis-lock;redis;fusion-cache</PackageTags>
         <Description>Pandatech.DistributedCache is a lightweight .NET library that extends the new HybridCache abstraction for seamless distributed caching on top of Redis. It provides strongly typed caching with MessagePack serialization, distributed locking, rate limiting, and stampede protection. With fewer than 500 lines of code, it is both easy to understand and simple to adopt, while still offering robust features for production environments.</Description>
         <RepositoryUrl>https://github.com/PandaTechAM/be-lib-distributed-cache</RepositoryUrl>
-        <PackageReleaseNotes>Nuget updates</PackageReleaseNotes>
+        <PackageReleaseNotes>Minor optimization in lock service</PackageReleaseNotes>
     </PropertyGroup>
 
     <ItemGroup>

src/DistributedCache/Services/Implementations/RedisLockService.cs

@@ -16,17 +16,17 @@ internal sealed class RedisLockService(IRedisClient redisClient, IOptions<CacheC
    private readonly IRedisDatabase _redisDatabase = redisClient.GetDefaultDatabase();
    private readonly TimeSpan _timeout = 2 * options.Value.DistributedLockMaxDuration;
 
-   public async Task<bool> AcquireLockAsync(string key, string lockValue)
+   public Task<bool> AcquireLockAsync(string key, string lockValue)
    {
       var lockKey = CacheKeyFormatter.BuildLockKey(key);
-      return await _redisDatabase.Database.StringSetAsync(lockKey, lockValue, _lockExpiry, When.NotExists);
+      return _redisDatabase.Database.StringSetAsync(lockKey, lockValue, _lockExpiry, When.NotExists);
    }
 
-   public async Task<bool> HasLockAsync(string key)
+   public Task<bool> HasLockAsync(string key)
    {
       var lockKey = CacheKeyFormatter.BuildLockKey(key);
 
-      return await _redisDatabase.Database.KeyExistsAsync(lockKey);
+      return _redisDatabase.Database.KeyExistsAsync(lockKey);
    }
 
    public async Task WaitUntilLockIsReleasedAsync(string key, CancellationToken token)
@@ -47,7 +47,7 @@ public async Task WaitUntilLockIsReleasedAsync(string key, CancellationToken tok
       }
    }
 
-   public async Task ReleaseLockAsync(string key, string lockValue)
+   public Task ReleaseLockAsync(string key, string lockValue)
    {
       var lockKey = CacheKeyFormatter.BuildLockKey(key);
       const string script = @"
@@ -57,6 +57,6 @@ public async Task ReleaseLockAsync(string key, string lockValue)
                     return 0
                 end";
 
-      await _redisDatabase.Database.ScriptEvaluateAsync(script, [lockKey], [lockValue]);
+      return _redisDatabase.Database.ScriptEvaluateAsync(script, [lockKey], [lockValue]);
    }
 }