PerThreadLifetimeManager的問題
使用Unity內置的PerThreadLifetimeManager生存期模型時,其基於ThreadStatic的TLS(Thread Local Storage)設計,也就是說對於每個托管的ManagedThreadId,其會緩存已生成的對象實例。
由於CLR維護了托管線程池,使用過的線程並不會立即銷毀,在需要的時候會繼續復用。在類似ASP.NET PerCall或WCF PerCall條件下,當Call1在線程ManagedThreadId1中處理完畢後,Call2發生,而Call2很有可能也在線程ManagedThreadId1中處理。這種條件下Call2會自動復用處理Call1時生成並緩存的對象實例。
如果我們希望每次調用(PerCall)都生成專用的對象實例,則PerThreadLifetimeManager在此種場景下不適合。
解決辦法有兩種:
1.繼續使用PerThreadLifetimeManager模型,不適用ThreadPool,而手動創建和銷毀線程。
2.自定義對象生存期模型
PerCallContextLifeTimeManager
復制代碼 代碼如下:
public class PerCallContextLifeTimeManager : LifetimeManager
{
private string _key =
string.Format(CultureInfo.InvariantCulture,
"PerCallContextLifeTimeManager_{0}", Guid.NewGuid());
public override object GetValue()
{
return CallContext.GetData(_key);
}
public override void SetValue(object newValue)
{
CallContext.SetData(_key, newValue);
}
public override void RemoveValue()
{
CallContext.FreeNamedDataSlot(_key);
}
}
使用舉例
復制代碼 代碼如下:
private static void TestPerCallContextLifeTimeManager()
{
IExample example;
using (IUnityContainer container = new UnityContainer())
{
container.RegisterType(typeof(IExample), typeof(Example),
new PerCallContextLifeTimeManager());
container.Resolve<IExample>().SayHello();
container.Resolve<IExample>().SayHello();
Action<int> action = delegate(int sleep)
{
container.Resolve<IExample>().SayHello();
Thread.Sleep(sleep);
container.Resolve<IExample>().SayHello();
};
Thread thread1 = new Thread((a) => action.Invoke((int)a));
Thread thread2 = new Thread((a) => action.Invoke((int)a));
thread1.Start(50);
thread2.Start(55);
thread1.Join();
thread2.Join();
ThreadPool.QueueUserWorkItem((a) => action.Invoke((int)a), 50);
ThreadPool.QueueUserWorkItem((a) => action.Invoke((int)a), 55);
Thread.Sleep(100);
ThreadPool.QueueUserWorkItem((a) => action.Invoke((int)a), 50);
ThreadPool.QueueUserWorkItem((a) => action.Invoke((int)a), 55);
Thread.Sleep(100);
ThreadPool.QueueUserWorkItem((a) => action.Invoke((int)a), 50);
ThreadPool.QueueUserWorkItem((a) => action.Invoke((int)a), 55);
Thread.Sleep(100);
example = container.Resolve<IExample>();
}
example.SayHello();
Console.ReadKey();
}