.Net Core中ObjectPool的使用与源码解析

一、对象池  

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

二、使用

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

DefaultObjectPool<User> defaultPool = new DefaultObjectPool<User>(new DefaultPooledObjectPolicy<User>(), 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<User>//需要继承抽象类
 {
  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<User> defaultPool = new DefaultObjectPool<User>(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<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():从对象池中获取对象。

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

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

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对我们的支持。

(0)

相关推荐

  • .Net Core中ObjectPool的使用与源码解析

    一.对象池 运用对象池化技术可以显著地提升性能,尤其是当对象的初始化过程代价较大或者频率较高.下面是ObjectPool源码中涉及的几个类.当你看过.Net Core源码很多时,你会发现,微软的开发很多都是这种模式,通过Policy构建Provider,通过Provider创建最终的类. 二.使用 这个组件的目的主要是将对象保存到对象池,用的时候直接去取,不需要重新创建,实现对象的重复利用.但是有个问题,假如对象池中开始没有对象或者取得数量大于对象池中的数量怎么办?在对象池中对象的数量不足时,此

  • 浅谈Vuejs中nextTick()异步更新队列源码解析

    vue官网关于此解释说明如下: vue2.0里面的深入响应式原理的异步更新队列 官网说明如下: 只要观察到数据变化,Vue 将开启一个队列,并缓冲在同一事件循环中发生的所有数据改变.如果同一个 watcher 被多次触发,只会一次推入到队列中.这种在缓冲时去除重复数据对于避免不必要的计算和 DOM 操作上非常重要.然后,在下一个的事件循环"tick"中,Vue 刷新队列并执行实际(已去重的)工作.Vue 在内部尝试对异步队列使用原生的 Promise.then 和 MutationOb

  • .NET Core源码解析配置文件及依赖注入

    写在前面 上篇文章我给大家讲解了ASP.NET Core的概念及为什么使用它,接着带着你一步一步的配置了.NET Core的开发环境并创建了一个ASP.NET Core的mvc项目,同时又通过一个实战教你如何在页面显示一个Content的列表.不知道你有没有跟着敲下代码,千万不要做眼高手低的人哦. 这篇文章我们就会设计一些复杂的概念了,因为要对ASP.NET Core的启动及运行原理.配置文件的加载过程进行分析,依赖注入,控制反转等概念的讲解等. 俗话说,授人以鱼不如授人以渔,所以文章旨在带着大

  • Android开发中线程池源码解析

    线程池(英语:thread pool):一种线程使用模式.线程过多会带来调度开销,进而影响缓存局部性和整体性能.而线程池维护着多个线程,等待着监督管理者分配可并发执行的任务.这避免了在处理短时间任务时创建与销毁线程的代价.线程池不仅能够保证内核的充分利用,还能防止过分调度.可用线程数量应该取决于可用的并发处理器.处理器内核.内存.网络sockets等的数量. 例如,线程数一般取cpu数量+2比较合适,线程数过多会导致额外的线程切换开销.----摘自维基百科 我们在Android或者Java开发中

  • 游戏服务器中的Netty应用以及源码剖析

    目录 一.Reactor模式和Netty线程模型 1. BIO模型 2. NIO模型 3. Reacor模型 ①. 单Reacor单线程模型 ②. 单Reactor多线程模型 ③. 主从Reactor多线程模型 ④. 部分源码分析 二.select/poll和epoll 1.概念 2.jdk提供selector 3.Netty提供的Epoll封装 4.Netty相关类图 5.配置Netty为EpollEventLoop 三.Netty相关参数 1.SO_KEEPALIVE 2.SO_REUSEA

  • Android 中 SwipeLayout一个展示条目底层菜单的侧滑控件源码解析

    由于项目上的需要侧滑条目展示收藏按钮,记得之前代码家有写过一个厉害的开源控件 AndroidSwipeLayout 本来准备直接拿来使用,但是看过 issue 发现现在有不少使用者反应有不少的 bug ,而且代码家现在貌似也不进行维护了.故自己实现了一个所要效果的一个控件.因为只是实现我需要的效果,所以大家也能看到,代码里有不少地方我是写死的.希望对大家有些帮助.而且暂时也不需要 AndroidSwipeLayout 大而全的功能,算是变相给自己做的项目精简代码了. 完整示例代码请看:GitHu

  • java中break和continue源码解析

    在自己学习java语言的过程中,很容易把break和continue的用法混淆.为了便于以后快速查阅及温习,在此特留学习笔记一份. 简述 在任何迭代语句的主体部分,都可以用break和continue控制循环的流程.其中,break用于强行退出循环,不执行循环中剩余的语句.而continue则停止执行当前迭代,然后退回循环起始处,开始下一次迭代. 源码 下面这个程序向大家展示了break和continue在for和while循环中的例子: package com.mufeng.thefourth

  • Java 中的FileReader和FileWriter源码分析_动力节点Java学院整理

    FileReader和FileWriter源码分析 1. FileReader 源码(基于jdk1.7.40) package java.io; public class FileReader extends InputStreamReader { public FileReader(String fileName) throws FileNotFoundException { super(new FileInputStream(fil java io系列21之 InputStreamReade

  • Java中的InputStreamReader和OutputStreamWriter源码分析_动力节点Java学院整理

    InputStreamReader和OutputStreamWriter源码分析 1. InputStreamReader 源码(基于jdk1.7.40) package java.io; import java.nio.charset.Charset; import java.nio.charset.CharsetDecoder; import sun.nio.cs.StreamDecoder; // 将"字节输入流"转换成"字符输入流" public class

  • Python中getpass模块无回显输入源码解析

    本文主要讨论了python中getpass模块的相关内容,具体如下. getpass模块 昨天跟学弟吹牛b安利Python标准库官方文档的时候偶然发现了这个模块.仔细一看内容挺少的,只有两个主要api,就花了点时间阅读了一下源码,感觉挺实用的,在这安利给大家. getpass.getpass(prompt='Password: ', stream=None) 调用该函数可以在命令行窗口里面无回显输入密码.参数prompt代表提示字符串,默认是'Password: '.在Unix系统中,strea

随机推荐