Java?Apache?common-pool對象池介紹

更新時間：2022年09月16日 08:35:39 作者：七路燈

這篇文章主要介紹了Java Apache?common-pool對象池介紹,文章通過圍繞主題展開詳細(xì)的內(nèi)容介紹，具有一定的參考價值，感興趣的小伙伴可以參考一下

對象生命周期

Config詳解

maxActive: 鏈接池中最大連接數(shù),默認(rèn)為8.
maxIdle: 鏈接池中最大空閑的連接數(shù),默認(rèn)為8.
minIdle: 連接池中最少空閑的連接數(shù),默認(rèn)為0.
maxWait: 當(dāng)連接池資源耗盡時，調(diào)用者最大阻塞的時間，超時將跑出異常。單位，毫秒數(shù);默認(rèn)為-1.表示永不超時.
minEvictableIdleTimeMillis: 連接空閑的最小時間，達(dá)到此值后空閑連接將可能會被移除。負(fù)值(-1)表示不移除。
softMinEvictableIdleTimeMillis: 連接空閑的最小時間，達(dá)到此值后空閑鏈接將會被移除，且保留“minIdle”個空閑連接數(shù)。默認(rèn)為-1.
numTestsPerEvictionRun: 對于“空閑鏈接”檢測線程而言，每次檢測的鏈接資源的個數(shù)。默認(rèn)為3.
testOnBorrow: 向調(diào)用者輸出“鏈接”資源時，是否檢測是有有效，如果無效則從連接池中移除，并嘗試獲取繼續(xù)獲取。默認(rèn)為false。建議保持默認(rèn)值.
testOnReturn: 向連接池“歸還”鏈接時，是否檢測“鏈接”對象的有效性。默認(rèn)為false。建議保持默認(rèn)值.
testWhileIdle: 向調(diào)用者輸出“鏈接”對象時，是否檢測它的空閑超時；默認(rèn)為false。如果“鏈接”空閑超時，將會被移除。建議保持默認(rèn)值.
timeBetweenEvictionRunsMillis: “空閑鏈接”檢測線程，檢測的周期，毫秒數(shù)。如果為負(fù)值，表示不運(yùn)行“檢測線程”。默認(rèn)為-1.
whenExhaustedAction: 當(dāng)“連接池”中active數(shù)量達(dá)到閥值時，即“鏈接”資源耗盡時，連接池需要采取的手段, 默認(rèn)為1：
- 0 : 拋出異常，
- 1 : 阻塞，直到有可用鏈接資源
- 2 : 強(qiáng)制創(chuàng)建新的鏈接資源

代碼說明

1. 整個方案從ObjectPool，PooledObjectFactory和PooledObject三個接口展開，
2. 其中ObjectPool定義了對象池要實(shí)現(xiàn)的功能【比如怎么存取，怎么過期】；
3. PooledObjectFactory定義了被池化的對象的創(chuàng)建，初始化，激活，鈍化以及銷毀功能；
4. PooledObject定了一被池化對象的一些附加信息【創(chuàng)建時間，池中狀態(tài)】；
5. 大概流程就是由PooledObjectFactory創(chuàng)建的對象經(jīng)過PooledObject的包裝然后放到ObjectPool里面來

ObjectPool

//從池中獲取對象
T borrowObject() throws Exception, NoSuchElementException,IllegalStateException;
//將對象放回池中
void returnObject(T obj) throws Exception;
//廢棄對象
void invalidateObject(T obj) throws Exception;
//添加對象
void addObject() throws Exception, IllegalStateException,UnsupportedOperationException;
//獲取對象個數(shù)
int getNumIdle();
//獲取活躍對象個數(shù)
int getNumActive();
//清除池，池可用
void clear() throws Exception, UnsupportedOperationException;
//關(guān)閉池，池不可用
void close();

PooledObjectFactory

//創(chuàng)建一個新對象;當(dāng)對象池中的對象個數(shù)不足時,將會使用此方法來"輸出"一個新的"對象",并交付給對象池管理
PooledObject<T> makeObject() throws Exception;
//銷毀對象,如果對象池中檢測到某個"對象"idle的時間超時,或者操作者向?qū)ο蟪?歸還對象"時檢測到"對象"已經(jīng)無效,那么此時將會導(dǎo)致"對象銷毀";"銷毀對象"的操作設(shè)計(jì)相差甚遠(yuǎn),但是必須明確:當(dāng)調(diào)用此方法時,"對象"的生命周期必須結(jié)束.如果object是線程,那么此時線程必須退出;如果object是socket操作,那么此時socket必須關(guān)閉;如果object是文件流操作,那么此時"數(shù)據(jù)flush"且正常關(guān)閉.
void destroyObject(PooledObject<T> p) throws Exception;
//檢測對象是否"有效";Pool中不能保存無效的"對象",因此"后臺檢測線程"會周期性的檢測Pool中"對象"的有效性,如果對象無效則會導(dǎo)致此對象從Pool中移除,并destroy;此外在調(diào)用者從Pool獲取一個"對象"時,也會檢測"對象"的有效性,確保不能講"無效"的對象輸出給調(diào)用者;當(dāng)調(diào)用者使用完畢將"對象歸還"到Pool時,仍然會檢測對象的有效性.所謂有效性,就是此"對象"的狀態(tài)是否符合預(yù)期,是否可以對調(diào)用者直接使用;如果對象是Socket,那么它的有效性就是socket的通道是否暢通/阻塞是否超時等.
boolean validateObject(PooledObject<T> p);
// "激活"對象,當(dāng)Pool中決定移除一個對象交付給調(diào)用者時額外的"激活"操作,比如可以在activateObject方法中"重置"參數(shù)列表讓調(diào)用者使用時感覺像一個"新創(chuàng)建"的對象一樣;如果object是一個線程,可以在"激活"操作中重置"線程中斷標(biāo)記",或者讓線程從阻塞中喚醒等;如果object是一個socket,那么可以在"激活操作"中刷新通道,或者對socket進(jìn)行鏈接重建(假如socket意外關(guān)閉)等.
void activateObject(PooledObject<T> p) throws Exception;
//"鈍化"對象,當(dāng)調(diào)用者"歸還對象"時,Pool將會"鈍化對象";鈍化的言外之意,就是此"對象"暫且需要"休息"一下.如果object是一個socket,那么可以passivateObject中清除buffer,將socket阻塞;如果object是一個線程,可以在"鈍化"操作中將線程sleep或者將線程中的某個對象wait.需要注意的時,activateObject和passivateObject兩個方法需要對應(yīng),避免死鎖或者"對象"狀態(tài)的混亂.
void passivateObject(PooledObject<T> p) throws Exception;

PooledObject

T getObject();
long getCreateTime();
long getActiveTimeMillis();
long getIdleTimeMillis();
long getLastBorrowTime();
long getLastReturnTime();
long getLastUsedTime();
int compareTo(PooledObject<T> other);
boolean equals(Object obj);
int hashCode();
String toString();
//后臺清理線程
boolean startEvictionTest();
boolean endEvictionTest(Deque<PooledObject<T>> idleQueue);
boolean allocate();
boolean deallocate();
void invalidate()
void setLogAbandoned(boolean logAbandoned);
void use();
void printStackTrace(PrintWriter writer);
PooledObjectState getState();
//自動補(bǔ)償功能
void markAbandoned();
void markReturning();