增加ConcurrentCache类型

Author: xljiulang

WebApiClient/Internal/ConcurrentCache.cs

@@ -0,0 +1,54 @@
+using System;
+using System.Collections;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace WebApiClient
+{
+    /// <summary>
+    /// 表示线程安全的内存缓存
+    /// </summary>
+    /// <typeparam name="TKey">键</typeparam>
+    /// <typeparam name="TValue">值</typeparam>
+    public class ConcurrentCache<TKey, TValue>
+    {
+        /// <summary>
+        /// 线程安全字典
+        /// </summary>
+        private readonly ConcurrentDictionary<TKey, Lazy<TValue>> dictionary;
+
+        /// <summary>
+        /// 线程安全的内存缓存
+        /// </summary>
+        public ConcurrentCache()
+        {
+            this.dictionary = new ConcurrentDictionary<TKey, Lazy<TValue>>();
+        }
+
+        /// <summary>
+        /// 线程安全的内存缓存
+        /// </summary>
+        /// <param name="comparer">键的比较器</param>
+        public ConcurrentCache(IEqualityComparer<TKey> comparer)
+        {
+            this.dictionary = new ConcurrentDictionary<TKey, Lazy<TValue>>(comparer);
+        }
+
+        /// <summary>
+        /// 获取或添加缓存
+        /// </summary>
+        /// <param name="key">键</param>
+        /// <param name="valueFactory">生成缓存内容的委托</param>
+        /// <returns></returns>
+        public TValue GetOrAdd(TKey key, Func<TKey, TValue> valueFactory)
+        {
+            return this.dictionary
+                .GetOrAdd(key, k => new Lazy<TValue>(() => valueFactory(k), LazyThreadSafetyMode.ExecutionAndPublication))
+                .Value;
+        }
+    }
+}

WebApiClient/Internal/HttpApiClientProxy.cs

@@ -37,7 +37,7 @@ static class HttpApiClientProxy
         /// <summary>
         /// 接口类型与代理类型的构造器缓存
         /// </summary>
-        private static readonly ConcurrentDictionary<Type, Lazy<ConstructorInfo>> proxyTypeCtorCache = new ConcurrentDictionary<Type, Lazy<ConstructorInfo>>();
+        private static readonly ConcurrentCache<Type, ConstructorInfo> proxyTypeCtorCache = new ConcurrentCache<Type, ConstructorInfo>();
 
         /// <summary>
         /// 创建HttpApiClient代理类
@@ -53,9 +53,9 @@ public static object CreateProxyWithInterface(Type interfaceType, IApiIntercepto
             var apiMethods = interfaceType.GetAllApiMethods();
             var proxyTypeCtor = proxyTypeCtorCache.GetOrAdd(
                 interfaceType,
-                @interface => new Lazy<ConstructorInfo>(() => @interface.ImplementAsHttpApiClient(apiMethods)));
+                @interface => @interface.ImplementAsHttpApiClient(apiMethods));
 
-            return proxyTypeCtor.Value.Invoke(new object[] { interceptor, apiMethods });
+            return proxyTypeCtor.Invoke(new object[] { interceptor, apiMethods });
         }
 
         /// <summary>

WebApiClient/Internal/TypeExtend.cs

@@ -16,14 +16,13 @@ static class TypeExtend
         /// <summary>
         /// 接口的方法缓存
         /// </summary>
-        private static readonly ConcurrentDictionary<Type, MethodInfo[]> interfaceMethodsCache = new ConcurrentDictionary<Type, MethodInfo[]>();
+        private static readonly ConcurrentCache<Type, MethodInfo[]> interfaceMethodsCache = new ConcurrentCache<Type, MethodInfo[]>();
 
         /// <summary>
         /// 类型是否AllowMultiple的缓存
         /// </summary>
         private static readonly ConcurrentDictionary<Type, bool> typeAllowMultipleCache = new ConcurrentDictionary<Type, bool>();
 
-
         /// <summary>
         /// 获取接口类型及其继承的接口的所有方法
         /// 忽略HttpApiClient类型的所有接口的方法