函数式编程-记忆化缓存
温暖如太阳 人气:0记忆化，是一种为了提高应用程序性能的FP技术。程序加速是通过缓存函数的结果实现的，避免了重复计算带来的额外开销。
1、现在我们使用Dictionary作为缓存结构
1 public static Func<T, R> Memoize<T, R>(Func<T, R> func)
2 where T : IComparable
3 {
4 Dictionary<T, R> cache = new Dictionary<T, R>();
5 return arg =>
6 {
7 if (cache.ContainsKey(arg))
8 return cache[arg];
9 return (cache[arg] = func(arg));
10 };
11 }
1 public static string GetString(string name)
2 {
3 return $"return date {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")} string {name}";
4 }
1 var getStrMemoize = Memoize<string, string>(GetString);
2 Console.WriteLine(getStrMemoize("A"));
3 Thread.Sleep(3000);
4 Console.WriteLine(getStrMemoize("B"));
5 Thread.Sleep(3000);
6 Console.WriteLine(getStrMemoize("A"));
打印结果：
1 return date 2020-12-31 08:37:12 string A 2 return date 2020-12-31 08:37:15 string B 3 return date 2020-12-31 08:37:12 string A
可以看出第三次打印的结果跟第一次打印的结果相同，也就是被缓存在Dictionary中的值。
在单线程中我们这样写没有问题，程序顺序被执行，Dictionary不存在并发问题，但是当我们想在多个线程并行时Dictionary不是线程安全集合，会存在线程安全问题。
2、现在我们使用线程安全集合ConcurrentDictionary进行改进：（方法中注释已经对方法做了说明，在此不重复）
1 /// <summary>
2 /// 使用线程安全集合
3 /// </summary>
4 /// <typeparam name="T"></typeparam>
5 /// <typeparam name="R"></typeparam>
6 /// <param name="func"></param>
7 /// 对于字典的修改和写入操作， ConcurrentDictionary<TKey,TValue> 使用细粒度锁定以确保线程安全。
8 /// 对字典进行 (读取操作时，将以无锁方式执行。) 不过，在 valueFactory 锁的外部调用委托，以避免在锁定下执行未知代码时可能产生的问题。
9 /// 因此，对于 GetOrAdd 类上的所有其他操作而言，不是原子的 ConcurrentDictionary<TKey,TValue> 。
10 /// 由于在生成值时，另一个线程可以插入键/值 valueFactory ，因此您不能信任这一点，
11 /// 因为已 valueFactory 执行，其生成的值将插入到字典中并返回。
12 /// 如果 GetOrAdd 在不同的线程上同时调用，则 valueFactory 可以多次调用，但只会将一个键/值对添加到字典中。
13 /// 返回值取决于字典中的键是否存在，以及是否在 GetOrAdd 调用之后但在生成值之前由另一个线程插入了键/值 valueFactory
14 /// (如果当前线程检查到Key不在字典中，那么会执行生成键值；但是在写入前如果有线程完成了写入键值，当前线程写入前检查到有写入值，则以已写入的为准)。
15 /// <returns></returns>
16 public static Func<T, R> MemoizeThreadSafe<T, R>(Func<T, R> func) where T : IComparable
17 {
18 ConcurrentDictionary<T, R> cache = new ConcurrentDictionary<T, R>();
19 return arg =>
20 {
21 return cache.GetOrAdd(arg, a => func(arg));
22 };
23 }
1 var getStrMemoize = MemoizeThreadSafe<string, string>(GetString);
2 Console.WriteLine(getStrMemoize("A"));
3 Thread.Sleep(3000);
4 Console.WriteLine(getStrMemoize("B"));
5 Thread.Sleep(3000);
6 Console.WriteLine(getStrMemoize("A"));
打印结果：
1 return date 2020-12-31 08:42:46 string A 2 return date 2020-12-31 08:42:49 string B 3 return date 2020-12-31 08:42:46 string A
注解中我们说明了ConcurrentDictionary是线程安全集合，但是当我们使用GetOrAdd时，由于该方法不是原子性的操作，当进行初始化时，可能多个线程同时进行初始化操作，带来了额外的开销。
3、为解决GetOrAdd非原子性操作重复初始化操作，引入延迟初始化（注解已详细说明）：
在看改进方法前我们先看下Lazy类的用法：
1 public class user
2 {
3 public string name { get; set; }
4 }
1 Lazy<user> user = new Lazy<user>();
2 if (!user.IsValueCreated)
3 Console.WriteLine("user 未创建.");
4 user.Value.name = "test";
5 if (user.IsValueCreated)
6 Console.WriteLine("user 已创建.");
输出：
1 user 未创建. 2 user 已创建.
以下为Lazy类代码片段，从代码我们看出在对象未使用（value）前，实例并未真正创建：
1 [NonSerialized]
2 private Func<T> m_valueFactory;
3
4 private object m_boxed;
5
6 public T Value
7 {
8 get
9 {
10 return LazyInitValue();
11 }
12 }
13 private T LazyInitValue()
14 {
15 Boxed boxed = null;
16 try
17 {
18 boxed = CreateValue();
19 m_boxed = boxed;
20 }
21 finally
22 {
23 }
24 return boxed.m_value;
25 }
26
27 private Boxed CreateValue()
28 {
29 Boxed boxed = null;
30 if (m_valueFactory != null) //() => func(arg)
31 {
32 try
33 {
34 Func<T> factory = m_valueFactory;
35
36 boxed = new Boxed(factory());
37 }
38 catch (Exception ex)
39 {
40 throw;
41 }
42 }
43
44
45 return boxed;
46 }
47
48 [Serializable]
49 class Boxed
50 {
51 internal Boxed(T value)
52 {
53 m_value = value;
54 }
55 internal T m_value;
56 }
现在我们看下改进方法：
1 /// <summary>
2 /// 为解决GetOrAdd 非原子性操作，
3 /// 重复初始化操作，引入Lazy类型、
4 /// 延迟初始化
5 /// </summary>
6 /// <typeparam name="T"></typeparam>
7 /// <typeparam name="R"></typeparam>
8 /// <param name="func"></param>
9 /// 使用延迟初始化来延迟创建大型或消耗大量资源的对象，或者执行大量占用资源的任务
10 /// ，尤其是在程序的生存期内可能不会发生这种创建或执行时。
11 /// 若要为迟缓初始化做好准备，请创建的实例 Lazy<T> 。
12 /// 你创建的对象的类型参数 Lazy<T> 指定你希望延迟初始化的对象的类型。
13 /// 用于创建对象的构造函数 Lazy<T> 确定初始化的特征。
14 /// 首次访问 Lazy<T>.Value 属性时出现延迟初始化。
15 /// <returns></returns>
16 public static Func<T, R> MemoizeLazyThreadSafe<T, R>(Func<T, R> func) where T : IComparable
17 {
18 ConcurrentDictionary<T, Lazy<R>> cache = new ConcurrentDictionary<T, Lazy<R>>();
19 return arg =>
20 {
21 return cache.GetOrAdd(arg, a => new Lazy<R>(() => func(arg))).Value;
22 };
23 }
到现在方法的线程安全、初始化加载问题都解决了，但是我们在解决重复计算的问题后却又不得不考虑缓存带来的内存损耗问题。我们实例化了ConcurrentDictionary对象，并且该对象作为强引用类型一直未被释放，那么GC是无法回收该对象，带来的问题是内存一直被占用，随着方法引用次数越来越多内存开销则会越来越大。
4、为解决该问题，我们引入过期时间，根据过期时间释放缓存值。
1 public static Func<T, R> MemoizeWeakWithTtl<T, R>(Func<T, R> func, TimeSpan ttl)
2 where T : class, IEquatable<T>
3 where R : class
4 {
5 var keyStore = new ConcurrentDictionary<int, T>();
6
7 T ReduceKey(T obj)
8 {
9 var oldObj = keyStore.GetOrAdd(obj.GetHashCode(), obj);
10 return obj.Equals(oldObj) ? oldObj : obj;
11 }
12
13 var cache = new ConditionalWeakTable<T, Tuple<R, DateTime>>();
14
15 Tuple<R, DateTime> FactoryFunc(T key) =>
16 new Tuple<R, DateTime>(func(key), DateTime.Now + ttl);
17
18 return arg =>
19 {
20 var key = ReduceKey(arg);
21 var value = cache.GetValue(key, FactoryFunc);
22 if (value.Item2 >= DateTime.Now)
23 return value.Item1;
24 value = FactoryFunc(key);
25 cache.Remove(key);
26 cache.Add(key, value);
27 return value.Item1;
28 };
29 }
其他实现方式，使用WeakReference弱引用类型（以下为使用示例）：
1 public class Cache
2 {
3 static Dictionary<int, WeakReference> _cache;
4
5 int regenCount = 0;
6
7 public Cache(int count)
8 {
9 _cache = new Dictionary<int, WeakReference>();
10
11 for (int i = 0; i < count; i++)
12 {
13 _cache.Add(i, new WeakReference(new Data(i), false));
14 }
15 }
16
17 public int Count
18 {
19 get { return _cache.Count; }
20 }
21
22 public int RegenerationCount
23 {
24 get { return regenCount; }
25 }
26
27 public Data this[int index]
28 {
29 get
30 {
31 Data d = _cache[index].Target as Data;
32 if (d == null)
33 {
34 Console.WriteLine("Regenerate object at {0}: Yes", index);
35 d = new Data(index);
36 _cache[index].Target = d;
37 regenCount++;
38 }
39 else
40 {
41 Console.WriteLine("Regenerate object at {0}: No", index);
42 }
43
44 return d;
45 }
46 }
47 }
48
49
50 public class Data
51 {
52 private byte[] _data;
53 private string _name;
54
55 public Data(int size)
56 {
57 _data = new byte[size * 1024];
58 _name = size.ToString();
59 }
60
61 // Simple property.
62 public string Name
63 {
64 get { return _name; }
65 }
66 }
1 int cacheSize = 50;
2 Random r = new Random();
3 Cache c = new Cache(cacheSize);
4
5 string DataName = "";
6 GC.Collect(0);
7
8 for (int i = 0; i < c.Count; i++)
9 {
10 int index = r.Next(c.Count);
11 DataName = c[index].Name;
12 }
13 double regenPercent = c.RegenerationCount / (double)c.Count;
14 Console.WriteLine("Cache size: {0}, Regenerated: {1:P2}%", c.Count, regenPercent);
打印结果：
1 Regenerate object at 46: Yes 2 Regenerate object at 5: Yes 3 Regenerate object at 6: Yes 4 Regenerate object at 31: Yes 5 Regenerate object at 1: Yes 6 Regenerate object at 33: Yes 7 Regenerate object at 11: Yes 8 Regenerate object at 5: No 9 Regenerate object at 37: Yes 10 Regenerate object at 15: Yes 11 Regenerate object at 25: Yes 12 Regenerate object at 14: No 13 Regenerate object at 16: Yes 14 Regenerate object at 20: Yes 15 Regenerate object at 10: Yes 16 Regenerate object at 14: No 17 Regenerate object at 17: Yes 18 Regenerate object at 28: Yes 19 Regenerate object at 7: Yes 20 Regenerate object at 34: Yes 21 Regenerate object at 45: Yes 22 Regenerate object at 33: No 23 Regenerate object at 29: Yes 24 Regenerate object at 32: Yes 25 Regenerate object at 32: No 26 Regenerate object at 4: No 27 Regenerate object at 42: Yes 28 Regenerate object at 6: No 29 Regenerate object at 16: No 30 Regenerate object at 36: Yes 31 Regenerate object at 12: Yes 32 Regenerate object at 9: Yes 33 Regenerate object at 43: Yes 34 Regenerate object at 12: No 35 Regenerate object at 49: Yes 36 Regenerate object at 37: No 37 Regenerate object at 36: No 38 Regenerate object at 44: Yes 39 Regenerate object at 22: Yes 40 Regenerate object at 31: No 41 Regenerate object at 1: No 42 Regenerate object at 24: No 43 Regenerate object at 23: Yes 44 Regenerate object at 38: Yes 45 Regenerate object at 6: No 46 Regenerate object at 31: No 47 Regenerate object at 28: No 48 Cache size: 50, Regenerated: 66.00%%
具体实现方式不在此实现。
加载全部内容