本文以apache common-pools為例

主要組成類

PooledObject（可被池化的物件)

預設實現DefaultPooledObject，裡面封裝了一個真正的使用者需要池化的物件object。

其中DefaultPooledObject裡面有兩個方法:

Exception borrowedBy ：用於記錄上次呼叫borrow時的堆疊，用於跟蹤程式碼呼叫情況

 @Override
    public synchronized boolean allocate() {
        if (state == PooledObjectState.IDLE) {
            state = PooledObjectState.ALLOCATED;
            lastBorrowTime = System.currentTimeMillis();
            lastUseTime = lastBorrowTime;
            borrowedCount++;
            if
 
 (logAbandoned) {
                        borrowedBy = new  AbandonedObjectCreatedException();
            } 
            return true;
        } else if (state == PooledObjectState.EVICTION) {
            // TODO Allocate anyway and ignore eviction test
            state = PooledObjectState.EVICTION_RETURN_TO_HEAD;
            return
 
 false;
        }
        // TODO if validating and testOnBorrow == true then pre-allocate for
        // performance
        return false;
    }

Exception usedBy： 同上，記錄use時的堆疊

  @Override
    public void use() {
        lastUseTime = System.currentTimeMillis();
        usedBy = new Exception("The last code to use this object was:"
 
);
    }

PooledObjectState

物件的狀態，也即生命週期

• allocated ：此物件被客戶端使用中
• idle ：在池中，處於空閒狀態
• eviction：在例項化GenericObjectPool物件時，內部會啟動一個EvictionTimer執行緒執行緒，定期（timeBetweenEvictionRunsMillis）執行evict方法，以EvictionPolicy策略destory 狀態處於idle過長的物件或idle數太多的時候。
• abandoned：當池中的物件被客戶端拿出後，若長時間（removeAbandonedTimeout）未返回池中，或沒有呼叫use方法，即被標記為拋棄的，當執行removeAbandoned方法時從池中destory，並若logAbandoned為true的話，則列印呼叫堆疊

PooledObjectFactory（物件建立工廠）

一般需要程式設計師繼承BasePooledObjectFactory，建立需要池化的物件：

 private static class ShardedJedisFactory implements PooledObjectFactory<ShardedJedis> {
    private List<JedisShardInfo> shards;
    private Hashing algo;
    private Pattern keyTagPattern;

    public ShardedJedisFactory(List<JedisShardInfo> shards, Hashing algo, Pattern keyTagPattern) {
      this.shards = shards;
      this.algo = algo;
      this.keyTagPattern = keyTagPattern;
    }

    @Override
    public PooledObject<ShardedJedis> makeObject() throws Exception {
      ShardedJedis jedis = new ShardedJedis(shards, algo, keyTagPattern);
      return new DefaultPooledObject<ShardedJedis>(jedis);
    }

    @Override
    public void destroyObject(PooledObject<ShardedJedis> pooledShardedJedis) throws Exception {
      final ShardedJedis shardedJedis = pooledShardedJedis.getObject();
      for (Jedis jedis : shardedJedis.getAllShards()) {
        if (jedis.isConnected()) {
          try {
            try {
              jedis.quit();
            } catch (Exception e) {

            }
            jedis.disconnect();
          } catch (Exception e) {

          }
        }
      }
    }

    @Override
    public boolean validateObject(PooledObject<ShardedJedis> pooledShardedJedis) {
      try {
        ShardedJedis jedis = pooledShardedJedis.getObject();
        for (Jedis shard : jedis.getAllShards()) {
          if (!shard.ping().equals("PONG")) {
            return false;
          }
        }
        return true;
      } catch (Exception ex) {
        return false;
      }
    }

    @Override
    public void activateObject(PooledObject<ShardedJedis> p) throws Exception {

    }

    @Override
    public void passivateObject(PooledObject<ShardedJedis> p) throws Exception {

    }
  }

GenericObjectPoolConfig(物件池配置)

• lifo：後進先出，或者先進先出
• maxWaitMillis：從idle佇列裡面取物件時，若阻塞的話，則最大等待時長
• minEvictableIdleTimeMillis：處於idle狀態超過此值時，會被destory
• softMinEvictableIdleTimeMillis：處於idle狀態超過此值，且處於idle狀態個數大於minIdle時會被destory ，正常情況下softMinEvictableIdleTimeMillis < minEvictableIdleTimeMillis
• numTestsPerEvictionRun: evict執行緒每次遍歷時evict的個數
• testOnCreate：當create物件時，是否測試池化的物件是否存活
• testOnBorrow： 同上，從池中borrow出來時測試
• testOnReturn：同上，歸還池中時測試
• testWhileIdle：同上，idle狀態時測試
• timeBetweenEvictionRunsMillis：evict執行緒每次間隔時間
• blockWhenExhausted：從池中取物件時，若池子用盡的話，是否阻塞等待一會maxWaitMillis
• jmxEnabled：jmx是否開啟監控

AbandonedConfig（防止物件洩露）

• abandoned：被拋棄的，即被池拋棄的設定（客戶端從池裡面取出去後，若長時間不歸還池中，則拋棄並destory）並通過配置可以設定是否logAbandoned，若true的話，則把拋棄物件時，列印相關的日誌（呼叫日誌）

主要流程

evict執行緒流程