ConcurrentDictionary多线程同步字典集合的使用方法
这篇文章运用简单易懂的例子给大家介绍ConcurrentDictionary多线程同步字典集合的使用方法,代码非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
为白水等地区用户提供了全套网页设计制作服务,及白水网站建设行业解决方案。主营业务为网站设计、做网站、白水网站设计,以传统方式定制建设网站,并提供域名空间备案等一条龙服务,秉承以专业、用心的态度为用户提供真诚的服务。我们深信只要达到每一位用户的要求,就会得到认可,从而选择与我们长期合作。这样,我们也可以走得更远!
在之前一段时间里面,我的基类多数使用lock和Hashtable组合实现多线程内缓存的冲突处理,不过有时候使用这两个搭配并不尽如人意,偶尔还是出现了集合已经加入的异常,对代码做多方的处理后依然如故,最后采用了.NET 4.0后才引入的ConcurrentDictionary多线程同步字典集合,问题顺利解决。
1、使用lock和Hashtable组合实现
在我的基类里面,构建业务对象,一般用BLLFactory
var result = BLLFactory.Instance.FindFirst(); Console.WriteLine(result.ToJson());
因此使用BLLFactory
HashTable表示键/值对的集合。在.NET Framework中,Hashtable是System.Collections命名空间提供的一个容器,用于处理和表现类似key-value的键值对,其中key通常可用来快速查找,同时key是区分大小写;value用于存储对应于key的值。Hashtable中key-value键值对均为object类型,所以Hashtable可以支持任何类型的keyvalue键值对,任何非 null 对象都可以用作键或值。
使用这种方式,偶尔在Web端,还是出现多线程访问冲突的问题,为此我们也可以使用多线程的测试代码来进行测试重现错误,
try{ Listlist = new List ();for (int i = 0; i < 10; i++) { Thread thread = new Thread(() =>{var result = BLLFactory .Instance.FindFirst(); Console.WriteLine(result.ToJson()); Console.WriteLine(); }); list.Add(thread); }for (int i = 0; i < list.Count; i++) { list[i].Start(); } }catch(Exception ex) { LogTextHelper.Error(ex); }
跟踪代码得到错误信息如下所示。
因此,从上面代码可以看到,使用lock(syncRoot)也无法出现的多线程冲突问题。
2、使用ConcurrentDictionary替代Hashtable
ConcurrentDictionary是.net4.0推出的一套线程安全集合里的其中一个,和它一起被发行的还有ConcurrentStack,ConcurrentQueue等类型,它们的单线程版本(线程不安全的,Queue,Stack,Dictionary)我们一定不会陌生。ConcurrentDictionary
System.Collections.Concurrent 命名空间提供多个线程安全集合类。当有多个线程并发访问集合时,应使用这些类代替 System.Collections 和 System.Collections.Generic 命名空间中的对应类型。
ConcurrentDictionary这个类提供了下面几个方法,用于对集合的处理
public bool TryAdd(TKey key, TValue value)public bool TryUpdate(TKey key, TValue newValue, TValue comparisonValue)public TValue this[TKey key] { get; set; }public TValue AddOrUpdate(TKey key, FuncaddValueFactory, Func updateValueFactory) public TValue AddOrUpdate(TKey key, TValue addValue, Func updateValueFactory)public TValue GetOrAdd(TKey key, TValue value)public TValue GetOrAdd(TKey key, Func valueFactory)
使用ConcurrentDictionary来替代Hashtable,我们来看看BLLFactory的类的实现代码如下所示。
////// 对业务类进行构造的工厂类/// ///业务对象类型 public class BLLFactorywhere T : class{//采用ConcurrentDictionary线程安全的集合类来缓存,替代Hashtableprivate static ConcurrentDictionary conCurrentCache = new ConcurrentDictionary (); /// /// 创建或者从缓存中获取对应业务类的实例/// public static T Instance {get{string CacheKey = typeof(T).FullName;return (T)conCurrentCache.GetOrAdd(CacheKey, s =>{var bll = Reflect.Create(typeof(T).FullName, typeof(T).Assembly.GetName().Name); //反射创建,并缓存return bll; }); } } }
我们可以看到代码简化了很多,而且使用前面的多线程测试代码,也顺利获取数据,不会出现异常了。
运行代码可以顺利实现,不会出现之前使用Hashtable出现的多线程访问异常了。
关于ConcurrentDictionary多线程同步字典集合的使用方法就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
文章标题:ConcurrentDictionary多线程同步字典集合的使用方法
URL分享:http://ybzwz.com/article/pshihp.html