溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章運用簡單易懂的例子給大家介紹ConcurrentDictionary多線程同步字典集合的使用方法，代碼非常詳細，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。
在之前一段時間里面，我的基類多數(shù)使用lock和Hashtable組合實現(xiàn)多線程內(nèi)緩存的沖突處理，不過有時候使用這兩個搭配并不盡如人意，偶爾還是出現(xiàn)了集合已經(jīng)加入的異常，對代碼做多方的處理后依然如故，最后采用了.NET 4.0后才引入的ConcurrentDictionary多線程同步字典集合，問題順利解決。
在我的基類里面，構(gòu)建業(yè)務對象，一般用BLLFactory<T>.Instance就可以獲得對應業(yè)務對象的應用了。
var result = BLLFactory<Customer>.Instance.FindFirst(); Console.WriteLine(result.ToJson());
因此使用BLLFactory<T>.Instance這個構(gòu)建對象后，把它們放到HashTable里面，由于需要設計多線程沖突處理，因此需要使用lock對象來實現(xiàn)鎖定的處理。
HashTable表示鍵/值對的集合。在.NET Framework中，Hashtable是System.Collections命名空間提供的一個容器，用于處理和表現(xiàn)類似key-value的鍵值對，其中key通?？捎脕砜焖俨檎?，同時key是區(qū)分大小寫；value用于存儲對應于key的值。Hashtable中key-value鍵值對均為object類型，所以Hashtable可以支持任何類型的keyvalue鍵值對，任何非 null 對象都可以用作鍵或值。
使用這種方式，偶爾在Web端，還是出現(xiàn)多線程訪問沖突的問題，為此我們也可以使用多線程的測試代碼來進行測試重現(xiàn)錯誤，
try{
List<Thread> list = new List<Thread>();for (int i = 0; i < 10; i++)
{
Thread thread = new Thread(() =>{var result = BLLFactory<Customer>.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)也無法出現(xiàn)的多線程沖突問題。
ConcurrentDictionary是.net4.0推出的一套線程安全集合里的其中一個，和它一起被發(fā)行的還有ConcurrentStack,ConcurrentQueue等類型，它們的單線程版本（線程不安全的,Queue,Stack,Dictionary）我們一定不會陌生。ConcurrentDictionary<TKey, TValue> 可由多個線程同時訪問，且線程安全，用法同Dictionary很多相同，但是多了一些方法。ConcurrentDictionary 屬于System.Collections.Concurrent 命名空間。
System.Collections.Concurrent 命名空間提供多個線程安全集合類。當有多個線程并發(fā)訪問集合時，應使用這些類代替 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, Func<TKey, TValue> addValueFactory, Func<TKey, TValue, TValue> updateValueFactory)
public TValue AddOrUpdate(TKey key, TValue addValue, Func<TKey, TValue, TValue> updateValueFactory)public TValue GetOrAdd(TKey key, TValue value)public TValue GetOrAdd(TKey key, Func<TKey, TValue> valueFactory)使用ConcurrentDictionary來替代Hashtable，我們來看看BLLFactory的類的實現(xiàn)代碼如下所示。
/// <summary>/// 對業(yè)務類進行構(gòu)造的工廠類/// </summary>/// <typeparam name="T">業(yè)務對象類型</typeparam>public class BLLFactory<T> where T : class{//采用ConcurrentDictionary線程安全的集合類來緩存，替代Hashtableprivate static ConcurrentDictionary<string, object> conCurrentCache = new ConcurrentDictionary<string, object>(); /// <summary>/// 創(chuàng)建或者從緩存中獲取對應業(yè)務類的實例/// </summary>public static T Instance
{get{string CacheKey = typeof(T).FullName;return (T)conCurrentCache.GetOrAdd(CacheKey, s =>{var bll = Reflect<T>.Create(typeof(T).FullName, typeof(T).Assembly.GetName().Name); //反射創(chuàng)建，并緩存return bll;
});
}
}
}我們可以看到代碼簡化了很多，而且使用前面的多線程測試代碼，也順利獲取數(shù)據(jù)，不會出現(xiàn)異常了。
運行代碼可以順利實現(xiàn)，不會出現(xiàn)之前使用Hashtable出現(xiàn)的多線程訪問異常了。
關于ConcurrentDictionary多線程同步字典集合的使用方法就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
免責聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進行舉報，并提供相關證據(jù)，一經(jīng)查實，將立刻刪除涉嫌侵權(quán)內(nèi)容。
