Fix releasing poolInitSemaphore

cnblogs-dudu · cnblogs-dudu · commit 80e479fcfdbf · 2019-05-06T18:24:14.000+08:00
diff --git a/Enyim.Caching/Memcached/MemcachedNode.cs b/Enyim.Caching/Memcached/MemcachedNode.cs
@@ -130,12 +130,19 @@ public IPooledSocketResult Acquire()
             if (!this.isInitialized)
             {
                 poolInitSemaphore.Wait();
-                if (!this.isInitialized)
+                try
                 {
-                    var startTime = DateTime.Now;
-                    this.internalPoolImpl.InitPool();
-                    this.isInitialized = true;
-                    _logger.LogInformation("MemcachedInitPool-cost: {0}ms", (DateTime.Now - startTime).TotalMilliseconds);
+                    if (!this.isInitialized)
+                    {
+                        var startTime = DateTime.Now;
+                        this.internalPoolImpl.InitPool();
+                        this.isInitialized = true;
+                        _logger.LogInformation("MemcachedInitPool-cost: {0}ms", (DateTime.Now - startTime).TotalMilliseconds);
+                    }
+                }
+                finally
+                {
+                    poolInitSemaphore.Release();
                 }
             }
 
@@ -151,10 +158,6 @@ public IPooledSocketResult Acquire()
                 result.Fail(message, e);
                 return result;
             }
-            finally
-            {
-                poolInitSemaphore.Release();
-            }
         }
 
         /// <summary>
@@ -166,12 +169,18 @@ public async Task<IPooledSocketResult> AcquireAsync()
             if (!this.isInitialized)
             {
                 await poolInitSemaphore.WaitAsync();
-                if (!this.isInitialized)
+                try
+                {
+                    if (!this.isInitialized)
+                    {
+                        var startTime = DateTime.Now;
+                        await this.internalPoolImpl.InitPoolAsync();
+                        this.isInitialized = true;
+                        _logger.LogInformation("MemcachedInitPool-cost: {0}ms", (DateTime.Now - startTime).TotalMilliseconds);
+                    }
+                }
+                finally
                 {
-                    var startTime = DateTime.Now;
-                    await this.internalPoolImpl.InitPoolAsync();
-                    this.isInitialized = true;
-                    _logger.LogInformation("MemcachedInitPool-cost: {0}ms", (DateTime.Now - startTime).TotalMilliseconds);
                     poolInitSemaphore.Release();
                 }
             }
