在之前一段時間里面,我的基類多數(shù)使用lock和Hashtable組合實現(xiàn)多線程內(nèi)緩存的沖突處理,不過有時候使用這兩個搭配并不盡如人意,偶爾還是出現(xiàn)了集合已經(jīng)加入的異常,對代碼做多方的處理后依然如故,最后采用了.NET 4.0后才引入的ConcurrentDictionary多線程同步字典集合,問題順利解決。
1、使用lock和Hashtable組合實現(xiàn)
在我的基類里面,構(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)的多線程沖突問題。
2、使用ConcurrentDictionary替代Hashtable
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線程安全的集合類來緩存,替代Hashtable
private 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替代Hashtable對多線程的對象緩存處理,能夠順利解決問題的時候,發(fā)現(xiàn)其訪問效率也是較之前有所提高,一舉兩得。