这里我只实现了插入一个缓存,以及读取的方法。
我读取缓存单元的逻辑是这样的:
从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; } } }
得到如下数据:
这样就实现了平滑的读取缓存数据而没有任何等待时间
当然这里还有些问题,比如说传递不同参数时的解决方法,但是由于我仅是在一个统计时需要这种缓存提高性能,所以暂没有考虑通用的传参方式。
如果大家对这个话题感兴趣,欢迎讨论。
示例下载:CHCache.rar(点击下载) |