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

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

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创建