自定义Unity生存期模型PerCallContextLifeTimeManager

自定义Unity生存期模型PerCallContextLifeTimeManager

PerThreadLifetimeManager的问题

使用Unity内置的PerThreadLifetimeManager生存期模型时，其基于ThreadStatic的TLS（Thread Local Storage）设计，也就是说对于每个托管的ManagedThreadId，其会缓存已生成的对象实例。

由于CLR维护了托管线程池，使用过的线程并不会立即销毁，在需要的时候会继续复用。在类似ASP.NET PerCall或WCF PerCall条件下，当Call1在线程ManagedThreadId1中处理完毕后，Call2发生，而Call2很有可能也在线程ManagedThreadId1中处理。这种条件下Call2会自动复用处理Call1时生成并缓存的对象实例。

如果我们希望每次调用（PerCall）都生成专用的对象实例，则PerThreadLifetimeManager在此种场景下不适合。

解决办法有两种：

继续使用PerThreadLifetimeManager模型，不适用ThreadPool，而手动创建和销毁线程。 自定义对象生存期模型

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();
    } 

 

 

 

标签:  C# ,  .NET ,  WCF ,  IoC ,  DI ,  Unity

作者： Leo_wl

　　　　

出处： http://HdhCmsTestcnblogs测试数据/Leo_wl/

　　　　

本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。

版权信息

查看更多关于自定义Unity生存期模型PerCallContextLifeTimeManager的详细内容...

声明：本文来自网络，不代表【好得很程序员自学网】立场，转载请注明出处：http://www.haodehen.cn/did46166