v3.0.0

Author: 2881099

SafeObjectPool.csproj

@@ -5,7 +5,7 @@
     <AssemblyName>SafeObjectPool</AssemblyName>
     <PackageId>SafeObjectPool</PackageId>
     <RootNamespace>SafeObjectPool</RootNamespace>
-    <Version>2.3.1</Version>
+    <Version>3.0.0</Version>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
     <PackageProjectUrl>https://github.com/2881099/SafeObjectPool</PackageProjectUrl>
     <Description>应用场景：连接池，资源池等等</Description>

SafeObjectPool.xml

@@ -1,6 +1,4 @@
 using System;
-using System.Collections.Generic;
-using System.Text;
 using System.Threading.Tasks;
 
 namespace SafeObjectPool
@@ -16,7 +14,7 @@ public class DefaultPolicy<T> : IPolicy<T>
         public int AsyncGetCapacity { get; set; } = 10000;
         public bool IsThrowGetTimeoutException { get; set; } = true;
         public bool IsAutoDisposeWithSystem { get; set; } = true;
-        public int CheckAvailableInterval { get; set; } = 5;
+        public int CheckAvailableInterval { get; set; } = 3;
 
         public Func<T> CreateObject;
         public Action<Object<T>> OnGetObject;
@@ -33,15 +31,13 @@ public void OnDestroy(T obj)
 
         public void OnGet(Object<T> obj)
         {
-            //Console.WriteLine("Get: " + obj);
             OnGetObject?.Invoke(obj);
         }
 
 #if net40
 #else
         public Task OnGetAsync(Object<T> obj)
         {
-            //Console.WriteLine("GetAsync: " + obj);
             OnGetObject?.Invoke(obj);
             return Task.FromResult(true);
         }
@@ -54,7 +50,6 @@ public void OnGetTimeout()
 
         public void OnReturn(Object<T> obj)
         {
-            //Console.WriteLine("Return: " + obj);
         }
 
         public bool OnCheckAvailable(Object<T> obj)

SafeObjectPool/DefaultPolicy.cs

@@ -1,6 +1,4 @@
 using System;
-using System.Collections.Generic;
-using System.Text;
 using System.Threading.Tasks;
 
 namespace SafeObjectPool
@@ -25,8 +23,9 @@ public interface IObjectPool<T> : IDisposable
         /// 将对象池设置为不可用，后续 Get/GetAsync 均会报错，同时启动后台定时检查服务恢复可用
         /// </summary>
         /// <param name="exception"></param>
+        /// <param name="lastGetTime"></param>
         /// <returns>由【可用】变成【不可用】时返回true，否则返回false</returns>
-        bool SetUnavailable(Exception exception);
+        bool SetUnavailable(Exception exception, DateTime lastGetTime);
 
         /// <summary>
         /// 统计对象池中的对象

SafeObjectPool/IObjectPool.cs

@@ -1,6 +1,4 @@
 using System;
-using System.Collections.Generic;
-using System.Text;
 using System.Threading.Tasks;
 
 namespace SafeObjectPool

SafeObjectPool/IPolicy.cs

@@ -1,6 +1,4 @@
 using System;
-using System.Collections.Generic;
-using System.Text;
 using System.Threading;
 
 namespace SafeObjectPool
@@ -16,7 +14,8 @@ public static Object<T> InitWith(IObjectPool<T> pool, int id, T value)
                 Id = id,
                 Value = value,
                 LastGetThreadId = Thread.CurrentThread.ManagedThreadId,
-                LastGetTime = DateTime.Now
+                LastGetTime = DateTime.Now,
+                LastGetTimeCopy = DateTime.Now
             };
         }
 
@@ -42,6 +41,7 @@ public static Object<T> InitWith(IObjectPool<T> pool, int id, T value)
 
         /// 最后获取时的时间
         public DateTime LastGetTime { get; internal set; }
+        public DateTime LastGetTimeCopy { get; internal set; }
 
         /// <summary>
         /// 最后归还时的时间