无缝的缓存读取:双存储缓存策略(2)
我读取缓存单元的逻辑是这样的：
从2个不同缓存读取当然是很容易了，但是比较复杂的就是向缓存写入的过程：
这里读取数据以及写入缓存时我使用了一个委托，在其它线程中仅在需要执行时才会执行。
这里除了首次写入缓存占用主线程时间（读取要等待）以外，其它时间都可以无延时的读取，实现了无缝的缓存。
但我们在委托中要操作缓存的元素Medium,所以要传递参数进其它线程，所以我这里使用了一个辅助类来传递参数进入其它线程：
using System;
namespace CHCache {
/// <summary>
/// 一个线程Helper，用于帮助多抛出线程时传递参数
/// </summary>
public class ThreadHelper {
Func<object> Fun { get; set; }
Medium Medium { get; set; }
/// <summary>
/// 通过构造函数来传递参数
/// </summary>
/// <param name="m">缓存单元</param>
/// <param name="fun">读取数据的委托</param>
public ThreadHelper(Medium m,Func<object> fun) {
Medium = m;
Fun = fun;
}
/// <summary>
/// 线程入口，ThreadStart委托所对应的方法
/// </summary>
public void Doit()
{
Medium.IsUpdating = true;
if (Medium.IsPrimary) {
Console.WriteLine("Begin write to 2.");
var ret = Fun.Invoke();
Medium.Secondary = ret;
Console.WriteLine("End write to 2.");
}
else {
Console.WriteLine("Begin write to 1.");
var ret = Fun.Invoke();
Medium.Primary = ret;
Console.WriteLine("End write to 1.");
}
Medium.IsUpdated = true;
Medium.IsUpdating = false;
}
}
}
这样我们就实现了在另个线程读取数据的过程，这样就在任何时候读取数据时都会无延时直接读取了。
结
最后我们写一个主函数来测试一下效果
/*
* http://www.cnblogs.com/chsword/
* chsword
* Date: 2009-3-31
* Time: 16:53
*/
using System;
using System.Threading;
namespace CHCache
{
class Program
{
public static void Main(string[] args)
{
var cache = new DictionaryCache();
Console.WriteLine("Init...4s，you can press the CTRL+C to close the console window.");
while (true)
{
cache.Add("1", GetValue);
Thread.Sleep(1000);
Console.WriteLine(cache["1"]);
}
}
/// <summary>
/// 获取数据的方法，假设是从数据库读取的，费时约4秒
/// </summary>
/// <returns></returns>
static object GetValue()
{
Thread.Sleep(4000);
return DateTime.Now;
}
}
}
得到如下数据：
这样就实现了平滑的读取缓存数据而没有任何等待时间
当然这里还有些问题，比如说传递不同参数时的解决方法，但是由于我仅是在一个统计时需要这种缓存提高性能，所以暂没有考虑通用的传参方式。
如果大家对这个话题感兴趣，欢迎讨论。