如何在.Net Core中使用ObjectPool

tangjin

作者

这篇文章给大家介绍如何在.Net Core中使用ObjectPool，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。

一、对象池　　

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

二、使用

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

DefaultObjectPool<User>defaultPool=newDefaultObjectPool<User>(newDefaultPooledObjectPolicy<User>(),2);

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

varuser1=newUser()
{
Age=18,
Name="MicroHeart"
};

varuser2=newUser()
{
Age=19,
Name="MicroHeart"
};

varuser3=newUser()
{
Age=20,
Name="MicroHeart"
};

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

varu1=defaultPool.Get();//从对象池中取一个对象，返回第一个放入的user1
varu2=defaultPool.Get();//从对象池中取一个对象，返回第二个放入的user2
varu3=defaultPool.Get();//此时对象池中没有对象了，获取对象调用的Policy的Create方法，而DefaultPooledObjectPolicy的Create方法的实现是：newT（），所以返回Age=0Name=null

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

现在自己创建一个的Policy

publicclassMyUserPolicy:PooledObjectPolicy<User>//需要继承抽象类
{
publicoverrideUserCreate()
{
returnnewUser()
{
Age=18,
Name="MicroHeart"
};
}

publicoverrideboolReturn(Useruser)
{
if(user.Age==18)
returnfalse;
returntrue;
}
}

DefaultObjectPool<User>defaultPool=newDefaultObjectPool<User>(newMyUserPolicy(),2);

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

varuser1=newUser()
{
Age=18,
Name="MicroHeart"
};

varuser2=newUser()
{
Age=19,
Name="MicroHeart"
};

varuser3=newUser()
{
Age=20,
Name="MicroHeart"
};

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

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

三、源码解析

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

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

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

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

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

ObjectPoolProvider：创建对象池(ObjectPool)

　　abstract ObjectPool<T> Create<T>(IPooledObjectPolicy<T> policy)：通过Policy创建ObjectPool

　　DefaultObjectPoolProvider：ObjectPoolProvider的默认实现类

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

ObjectPool<T>：对象池

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