如何在.Net Core中使用ObjectPool
创始人
2024-11-27 12:45:25
0次

一、对象池  

运用对象池化技术可以显著地提升性能,尤其是当对象的初始化过程代价较大或者频率较高。下面是ObjectPool源码中涉及的几个类。当你看过.Net Core源码很多时,你会发现,微软的开发很多都是这种模式,通过Policy构建Provider,通过Provider创建最终的类。

如何在.Net Core中使用ObjectPool

二、使用

这个组件的目的主要是将对象保存到对象池,用的时候直接去取,不需要重新创建,实现对象的重复利用。但是有个问题,假如对象池中开始没有对象或者取得数量大于对象池中的数量怎么办?在对象池中对象的数量不足时,此时来取对象,需要通过Policy创建对象,至于怎么创建对象,是你需要实现的。Policy如上图,有个默认实现  DefaultPooledObjectPolicy ,它的创建就是 new T().

DefaultObjectPool defaultPool = new DefaultObjectPool(new DefaultPooledObjectPolicy(), 2);

   var firstUser=defaultPool.Get();//从对象池中取一个对象,此时对象池中还没有对象,返回 Age=0 Name=null

   var user1 = new User()
   {
    Age = 18,
    Name = "MicroHeart"
   };

   var user2 = new User()
   {
    Age = 19,
    Name = "MicroHeart"
   };

   var user3 = new User()
   {
    Age = 20,
    Name = "MicroHeart"
   };

   defaultPool.Return(user1);//将对象放回对象池中,但是不一定成功。对象池有数量限制,而且也可以自定义限制,让一些对象不能放入对象池中
   defaultPool.Return(user2);
   defaultPool.Return(user3);

   var u1 = defaultPool.Get();//从对象池中取一个对象,返回第一个放入的user1
   var u2 = defaultPool.Get();//从对象池中取一个对象,返回第二个放入的user2
   var u3 = defaultPool.Get();//此时对象池中没有对象了,获取对象调用的Policy的Create方法,而DefaultPooledObjectPolicy的Create方法的实现是:new T(),所以返回 Age=0 Name=null

上面例子当对象池中没有对象是,调取获取方法,其实就是new T()。下面在对象中添加3个对象,但是对象池中只有2个空间,所以第三个是添加不进去的。

现在自己创建一个的Policy

public class MyUserPolicy : PooledObjectPolicy//需要继承抽象类
 {
  public override User Create()
  {
   return new User()
   {
    Age = 18,
    Name = "MicroHeart"
   };
  }

  public override bool Return(User user)
  {
   if (user.Age == 18)
    return false;
   return true;
  }
 }
DefaultObjectPool defaultPool = new DefaultObjectPool(new MyUserPolicy(), 2);

   var firstUser=defaultPool.Get();//返回 Age=0 Name=null

   var user1 = new User()
   {
    Age = 18,
    Name = "MicroHeart"
   };

   var user2 = new User()
   {
    Age = 19,
    Name = "MicroHeart"
   };

   var user3 = new User()
   {
    Age = 20,
    Name = "MicroHeart"
   };

   defaultPool.Return(user1);
   defaultPool.Return(user2);
   defaultPool.Return(user3);

   var u1 = defaultPool.Get();//返回user2 因为user1的Age=18,policy中Reture筛选条件 返回false,导致第一个user不能放入连接池中。
   var u2 = defaultPool.Get();//返回user3
   var u3 = defaultPool.Get();//返回 Age=18 Name=MicroHeart 这个是使用 Policy中的Create创建

三、源码解析

 IPooledObjectPolicy:  主要作用是创建对象和将对象放入连接池中

  Create:定义一个创建对象的方法,当连接池中的数量不够取的时候,通过此方法创建对象。

  Return:将对象放入连接池中,如果放入成功,返回Ture.否则返回False.
  DefaultPooledObjectPolicy:继承抽象类PooledObjectPolicy,而抽抽象类继承接口 IPooledObjectPolicy。Policy的默认实现类

    Create:定义一个默认创建对象的方法 new T();

    Return:不论是否放入连接池,全部返回True.

ObjectPoolProvider:创建对象池(ObjectPool)

  abstract ObjectPool Create(IPooledObjectPolicy policy):通过Policy创建ObjectPool

  DefaultObjectPoolProvider:ObjectPoolProvider的默认实现类

    ObjectPool Create(IPooledObjectPolicy policy) :创建一个可以容纳处理器数量X2的对象池。

ObjectPool:对象池

  T Get():从对象池中获取对象。

  void Return(T obj):将对象放入对象池中。

  DefaultObjectPool:对象池的默认实现类,它实现了Get和Return方法。其实对象池的本质就是它的中的 ObjectWrapper[] _items; ,当使用Return方法是,将对象放入 ObjectWrapper数组中。Get方法从数组中取。

如何在.Net Core中使用ObjectPool

相关内容

热门资讯

空调连续工作多久需要停机休息 空调连续工作的时间取决于多个因素,包括空调的型号、功率、使用环境和维护情况等。一般来说,空调可以连续...
空调哪个符号是除湿的 空调除湿功能通常用一个水滴形状的符号表示。不同品牌和型号的空调遥控器可能会有所差异,但一般来说,除湿...
格力空调多长时间加一次氟利昂 1、一般情况下,空调对氟利昂的使用量是非常小的,所以在空调使用了四年左右的时候再考虑加也没问题。2、...
空调用多长时间需要加氟一次 一般情况下是五年。当出现以下这几种情况时,空调才需要加氟。1、空调的室内机和室外机各有两个接口,当接...
格调生活·C标思享荟:卡萨帝在... 9月12日的郑州龙湖金融岛,夜风轻拂,灯光璀璨。“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑...
品牌价值破千亿、高端份额持续领... 9月12日,“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑州站”在郑州龙湖金融岛举办。2026...
空调主板坏了修800还是换新的 空调主板坏了是修还是换新,需要考虑多个因素,以下是一些建议:1. 维修成本:如果维修费用较低,比如 ...
空调开多久需要休息多长时间 问题:空调开多久需要休息多长时间回答:1、在使用空调的过程中,一般空调开7~8个小时左右需要休息2~...
中央空调多长时间清洗一次 1、一般空调开机前清洗一次即可,空调开机中间时段再清洗一次,空调关机时清洗一次,这样比较合理。2、空...
中央空调氟利昂多久加一次 看空调制热和制冷程度,很多人的观点认为氟利昂必须一年放一次,其实这个观点是错误的,理解上面有点偏差,...