這篇文章運(yùn)用簡(jiǎn)單易懂的例子給大家介紹ConcurrentDictionary多線程同步字典集合的使用方法,代碼非常詳細(xì),感興趣的小伙伴們可以參考借鑒,希望對(duì)大家能有所幫助。
為白水等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計(jì)制作服務(wù),及白水網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為網(wǎng)站設(shè)計(jì)、做網(wǎng)站、白水網(wǎng)站設(shè)計(jì),以傳統(tǒng)方式定制建設(shè)網(wǎng)站,并提供域名空間備案等一條龍服務(wù),秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求,就會(huì)得到認(rèn)可,從而選擇與我們長(zhǎng)期合作。這樣,我們也可以走得更遠(yuǎn)!
在之前一段時(shí)間里面,我的基類多數(shù)使用lock和Hashtable組合實(shí)現(xiàn)多線程內(nèi)緩存的沖突處理,不過有時(shí)候使用這兩個(gè)搭配并不盡如人意,偶爾還是出現(xiàn)了集合已經(jīng)加入的異常,對(duì)代碼做多方的處理后依然如故,最后采用了.NET 4.0后才引入的ConcurrentDictionary多線程同步字典集合,問題順利解決。
在我的基類里面,構(gòu)建業(yè)務(wù)對(duì)象,一般用BLLFactory
var result = BLLFactory.Instance.FindFirst(); Console.WriteLine(result.ToJson());
因此使用BLLFactory
HashTable表示鍵/值對(duì)的集合。在.NET Framework中,Hashtable是System.Collections命名空間提供的一個(gè)容器,用于處理和表現(xiàn)類似key-value的鍵值對(duì),其中key通常可用來快速查找,同時(shí)key是區(qū)分大小寫;value用于存儲(chǔ)對(duì)應(yīng)于key的值。Hashtable中key-value鍵值對(duì)均為object類型,所以Hashtable可以支持任何類型的keyvalue鍵值對(duì),任何非 null 對(duì)象都可以用作鍵或值。
使用這種方式,偶爾在Web端,還是出現(xiàn)多線程訪問沖突的問題,為此我們也可以使用多線程的測(cè)試代碼來進(jìn)行測(cè)試重現(xiàn)錯(cuò)誤,
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); }
跟蹤代碼得到錯(cuò)誤信息如下所示。
因此,從上面代碼可以看到,使用lock(syncRoot)也無法出現(xiàn)的多線程沖突問題。
ConcurrentDictionary是.net4.0推出的一套線程安全集合里的其中一個(gè),和它一起被發(fā)行的還有ConcurrentStack,ConcurrentQueue等類型,它們的單線程版本(線程不安全的,Queue,Stack,Dictionary)我們一定不會(huì)陌生。ConcurrentDictionary
System.Collections.Concurrent 命名空間提供多個(gè)線程安全集合類。當(dāng)有多個(gè)線程并發(fā)訪問集合時(shí),應(yīng)使用這些類代替 System.Collections 和 System.Collections.Generic 命名空間中的對(duì)應(yīng)類型。
ConcurrentDictionary這個(gè)類提供了下面幾個(gè)方法,用于對(duì)集合的處理
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的類的實(shí)現(xiàn)代碼如下所示。
////// 對(duì)業(yè)務(wù)類進(jìn)行構(gòu)造的工廠類/// ///業(yè)務(wù)對(duì)象類型 public class BLLFactorywhere T : class{//采用ConcurrentDictionary線程安全的集合類來緩存,替代Hashtableprivate static ConcurrentDictionary conCurrentCache = new ConcurrentDictionary (); /// /// 創(chuàng)建或者從緩存中獲取對(duì)應(yīng)業(yè)務(wù)類的實(shí)例/// 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); //反射創(chuàng)建,并緩存return bll; }); } } }
我們可以看到代碼簡(jiǎn)化了很多,而且使用前面的多線程測(cè)試代碼,也順利獲取數(shù)據(jù),不會(huì)出現(xiàn)異常了。
運(yùn)行代碼可以順利實(shí)現(xiàn),不會(huì)出現(xiàn)之前使用Hashtable出現(xiàn)的多線程訪問異常了。
關(guān)于ConcurrentDictionary多線程同步字典集合的使用方法就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到。