對(duì)象池顧名思義就是存放對(duì)象的池，與我們常聽到的線程池、數(shù)據(jù)庫連接池、http連接池等一樣，都是典型的池化設(shè)計(jì)思想。
對(duì)象池的優(yōu)點(diǎn)就是可以集中管理池中對(duì)象，減少頻繁創(chuàng)建和銷毀長期使用的對(duì)象，從而提升復(fù)用性，以節(jié)約資源的消耗，可以有效避免頻繁為對(duì)象分配內(nèi)存和釋放堆中內(nèi)存，進(jìn)而減輕jvm垃圾收集器的負(fù)擔(dān)，避免內(nèi)存抖動(dòng)。
Apache Common Pool2 是Apache提供的一個(gè)通用對(duì)象池技術(shù)實(shí)現(xiàn)，可以方便定制化自己需要的對(duì)象池，大名鼎鼎的 Redis 客戶端 Jedis 內(nèi)部連接池就是基于它來實(shí)現(xiàn)的。
2021年最新阿里P7 Java面試題流出，附完整答案詳解，看完跳槽吊打面試官
核心接口
Apache Common Pool2 的核心內(nèi)部類如下：
ObjectPool：對(duì)象池接口，對(duì)象池實(shí)體，取用對(duì)象的地方
對(duì)象的提供與歸還(工廠來操作)：borrowObjectreturnObject
創(chuàng)建對(duì)象(使用工廠來創(chuàng)建)：addObject
銷毀對(duì)象(使用工廠來銷毀)：invalidateObject
池中空閑對(duì)象數(shù)量、被使用對(duì)象數(shù)量：getNumActivegetNumIdle
PooledObject：被包裝的對(duì)象，是池中的對(duì)象，除了對(duì)象本身之外包含了創(chuàng)建時(shí)間、上次被調(diào)用時(shí)間等眾多信息
PooledObjectFactory：對(duì)象工廠，管理對(duì)象的生命周期，提供了對(duì)象創(chuàng)建、銷毀、驗(yàn)證、鈍化、激活等一系列功能
BaseObjectPoolConfig：提供一些必要的配置，例如空閑隊(duì)列是否先進(jìn)先出、工廠創(chuàng)建對(duì)象前是否需要測(cè)試、對(duì)象從對(duì)象池取出時(shí)是否測(cè)試等基礎(chǔ)屬性，GenericObjectPoolConfig繼承了本類做了默認(rèn)配置，我們?cè)趯?shí)際使用中繼承它即可，可以結(jié)合業(yè)務(wù)情況擴(kuò)展對(duì)象池配置，例如數(shù)據(jù)庫連接池線程前綴、字符串池長度或名稱規(guī)則等
KeyedObjectPool<K,V>：鍵值對(duì)形式的對(duì)象池接口，使用場(chǎng)景很少
KeyedPooledObjectFactory<K,V>：同上，為鍵值對(duì)對(duì)象池管理對(duì)象的工廠
池對(duì)象的狀態(tài)
查看源碼PooledObjectState枚舉下列出了池對(duì)象所有可能處于的狀態(tài)。
public enum PooledObjectState {
? ? //在空閑隊(duì)列中,還未被使用
? ? IDLE,
? ? //使用中
? ? ALLOCATED,
? ? //在空閑隊(duì)列中,當(dāng)前正在測(cè)試是否滿足被驅(qū)逐的條件
? ? EVICTION,
? ? ? //不在空閑隊(duì)列中，目前正在測(cè)試是否可能被驅(qū)逐。因?yàn)樵跍y(cè)試過程中，試圖借用對(duì)象，并將其從隊(duì)列中刪除。
? ? //回收測(cè)試完成后，它應(yīng)該被返回到隊(duì)列的頭部。
? ? EVICTION_RETURN_TO_HEAD,
? ? ? //在隊(duì)列中，正在被校驗(yàn)
? ? VALIDATION,
? ? ? //不在隊(duì)列中，當(dāng)前正在驗(yàn)證。該對(duì)象在驗(yàn)證時(shí)被借用，由于配置了testOnBorrow，
? ? //所以將其從隊(duì)列中刪除并預(yù)先分配。一旦驗(yàn)證完成，就應(yīng)該分配它。
? ? VALIDATION_PREALLOCATED,
? ? ? //不在隊(duì)列中，當(dāng)前正在驗(yàn)證。在之前測(cè)試是否將該對(duì)象從隊(duì)列中移除時(shí)，曾嘗試借用該對(duì)象。
? ? //一旦驗(yàn)證完成，它應(yīng)該被返回到隊(duì)列的頭部。
? ? VALIDATION_RETURN_TO_HEAD,
? ? ? //無效狀態(tài)(如驅(qū)逐測(cè)試或驗(yàn)證)，并將/已被銷毀
? ? INVALID,
? ? ? //判定為無效,將會(huì)被設(shè)置為廢棄
? ? ABANDONED,
? ? ? //正在使用完畢,返回池中
? ? RETURNING
}
狀態(tài)理解
abandoned ：被借出后，長時(shí)間未被使用則被標(biāo)記為該狀態(tài)。如代碼所示，當(dāng)該對(duì)象處于ALLOCATED狀態(tài)，即被借出使用中，距離上次被使用的時(shí)間超過了設(shè)置的getRemoveAbandonedTimeout則被標(biāo)記為廢棄。
private void removeAbandoned(final AbandonedConfig abandonedConfig) {
? ? ? ? ? ? // Generate a list of abandoned objects to remove
? ? ? ? ? ? final long now = System.currentTimeMillis();
? ? ? ? ? ? final long timeout =
? ? ? ? ? ? ? ? ? ? now - (abandonedConfig.getRemoveAbandonedTimeout() * 1000L);
? ? ? ? ? ? final ArrayList<PooledObject<T>> remove = new ArrayList<>();
? ? ? ? ? ? final Iterator<PooledObject<T>> it = allObjects.values().iterator();
? ? ? ? ? ? while (it.hasNext()) {
? ? ? ? ? ? ? ? final PooledObject<T> pooledObject = it.next();
? ? ? ? ? ? ? ? synchronized (pooledObject) {
? ? ? ? ? ? ? ? ? ? if (pooledObject.getState() == PooledObjectState.ALLOCATED &&
? ? ? ? ? ? ? ? ? ? ? ? ? ? pooledObject.getLastUsedTime() <= timeout) {
? ? ? ? ? ? ? ? ? ? ? ? pooledObject.markAbandoned();
? ? ? ? ? ? ? ? ? ? ? ? remove.add(pooledObject);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? ```
## 流程理解
1.對(duì)象真實(shí)是存儲(chǔ)在哪里？
```java
private PooledObject<T> create() throws Exception {
? ? ? ? .....
? ? ? ? final PooledObject<T> p;
? ? ? ? try {
? ? ? ? ? ? p = factory.makeObject();
? ? ? ? .....
? ? ? ? allObjects.put(new IdentityWrapper<>(p.getObject()), p);
? ? ? ? return p;
}
我們查看allObjects，所有對(duì)象都存儲(chǔ)于ConcurrentHashMap，除了被殺掉的對(duì)象。
/*
? ? * All of the objects currently associated with this pool in any state. It
? ? * excludes objects that have been destroyed. The size of
? ? * {@link #allObjects} will always be less than or equal to {@link
? ? * #_maxActive}. Map keys are pooled objects, values are the PooledObject
? ? * wrappers used internally by the pool.
? ? */
? ? private final Map<IdentityWrapper<T>, PooledObject<T>> allObjects =
? ? ? ? new ConcurrentHashMap<>();
2.取用對(duì)象的邏輯歸納如下
首先根據(jù)AbandonedConfig配置判斷是否取用對(duì)象前執(zhí)行清理操作
再從idleObject中嘗試獲取對(duì)象，獲取不到就創(chuàng)建新的對(duì)象
判斷blockWhenExhausted是否設(shè)置為true，(這個(gè)配置的意思是當(dāng)對(duì)象池的active狀態(tài)的對(duì)象數(shù)量已經(jīng)達(dá)到最大值maxinum時(shí)是否進(jìn)行阻塞直到有空閑對(duì)象)
是的話按照設(shè)置的borrowMaxWaitMillis屬性等待可用對(duì)象
有可用對(duì)象后調(diào)用工廠的factory.activateObject方法激活對(duì)象
當(dāng)getTestOnBorrow設(shè)置為true時(shí)，調(diào)用factory.validateObject(p)對(duì)對(duì)象進(jìn)行校驗(yàn)，通過校驗(yàn)后執(zhí)行下一步
調(diào)用updateStatsBorrow方法，在對(duì)象被成功借出后更新一些統(tǒng)計(jì)項(xiàng)，例如返回對(duì)象池的對(duì)象個(gè)數(shù)等
//....
private final LinkedBlockingDeque<PooledObject<T>> idleObjects;
//....
public T borrowObject(final long borrowMaxWaitMillis) throws Exception {
? ? assertOpen();
? ? final AbandonedConfig ac = this.abandonedConfig;
? ? if (ac != null && ac.getRemoveAbandonedOnBorrow() &&
? ? ? ? ? ? (getNumIdle() < 2) &&
? ? ? ? ? ? (getNumActive() > getMaxTotal() - 3) ) {
? ? ? ? removeAbandoned(ac);
? ? }
? ? PooledObject<T> p = null;
? ? // Get local copy of current config so it is consistent for entire
? ? // method execution
? ? final boolean blockWhenExhausted = getBlockWhenExhausted();
? ? boolean create;
? ? final long waitTime = System.currentTimeMillis();
? ? while (p == null) {
? ? ? ? create = false;
? ? ? ? p = idleObjects.pollFirst();
? ? ? ? if (p == null) {
? ? ? ? ? ? p = create();
? ? ? ? ? ? if (p != null) {
? ? ? ? ? ? ? ? create = true;
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? if (blockWhenExhausted) {
? ? ? ? ? ? if (p == null) {
? ? ? ? ? ? ? ? if (borrowMaxWaitMillis < 0) {
? ? ? ? ? ? ? ? ? ? p = idleObjects.takeFirst();
? ? ? ? ? ? ? ? } else {
? ? ? ? ? ? ? ? ? ? p = idleObjects.pollFirst(borrowMaxWaitMillis,
? ? ? ? ? ? ? ? ? ? ? ? ? ? TimeUnit.MILLISECONDS);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? if (p == null) {
? ? ? ? ? ? ? ? throw new NoSuchElementException(
? ? ? ? ? ? ? ? ? ? ? ? "Timeout waiting for idle object");
? ? ? ? ? ? }
? ? ? ? } else {
? ? ? ? ? ? if (p == null) {
? ? ? ? ? ? ? ? throw new NoSuchElementException("Pool exhausted");
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? if (!p.allocate()) {
? ? ? ? ? ? p = null;
? ? ? ? }
? ? ? ? if (p != null) {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? factory.activateObject(p);
? ? ? ? ? ? } catch (final Exception e) {
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? destroy(p, DestroyMode.NORMAL);
? ? ? ? ? ? ? ? } catch (final Exception e1) {
? ? ? ? ? ? ? ? ? ? // Ignore - activation failure is more important
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? p = null;
? ? ? ? ? ? ? ? if (create) {
? ? ? ? ? ? ? ? ? ? final NoSuchElementException nsee = new NoSuchElementException(
? ? ? ? ? ? ? ? ? ? ? ? ? ? "Unable to activate object");
? ? ? ? ? ? ? ? ? ? nsee.initCause(e);
? ? ? ? ? ? ? ? ? ? throw nsee;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? if (p != null && getTestOnBorrow()) {
? ? ? ? ? ? ? ? boolean validate = false;
? ? ? ? ? ? ? ? Throwable validationThrowable = null;
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? validate = factory.validateObject(p);
? ? ? ? ? ? ? ? } catch (final Throwable t) {
? ? ? ? ? ? ? ? ? ? PoolUtils.checkRethrow(t);
? ? ? ? ? ? ? ? ? ? validationThrowable = t;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? if (!validate) {
? ? ? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ? ? destroy(p, DestroyMode.NORMAL);
? ? ? ? ? ? ? ? ? ? ? ? destroyedByBorrowValidationCount.incrementAndGet();
? ? ? ? ? ? ? ? ? ? } catch (final Exception e) {
? ? ? ? ? ? ? ? ? ? ? ? // Ignore - validation failure is more important
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? p = null;
? ? ? ? ? ? ? ? ? ? if (create) {
? ? ? ? ? ? ? ? ? ? ? ? final NoSuchElementException nsee = new NoSuchElementException(
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? "Unable to validate object");
? ? ? ? ? ? ? ? ? ? ? ? nsee.initCause(validationThrowable);
? ? ? ? ? ? ? ? ? ? ? ? throw nsee;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? }
? ? updateStatsBorrow(p, System.currentTimeMillis() - waitTime);
? ? return p.getObject();
}
3.工廠的passivateObject(PooledObject<T> p)和passivateObject(PooledObject<T> p)即對(duì)象的激活和鈍化方法有什么用？
如圖在對(duì)象使用完被返回對(duì)象池時(shí)，如果校驗(yàn)失敗直接銷毀，如果校驗(yàn)通過需要先鈍化對(duì)象再存入空閑隊(duì)列。至于激活對(duì)象的方法在上述取用對(duì)象時(shí)也會(huì)先激活再被取出。
因此我們可以發(fā)現(xiàn)處于空閑和使用中的對(duì)象他們除了狀態(tài)不一致，我們也可以通過激活和鈍化的方式在他們之間增加新的差異，例如我們要做一個(gè)Elasticsearch連接池，每個(gè)對(duì)象就是一個(gè)帶有ip和端口的連接實(shí)例，很顯然訪問es集群是多個(gè)不同的ip，所以每次訪問的ip不一定相同，我們則可以在激活操作為對(duì)象賦值ip和端口，鈍化操作中將ip和端口歸為默認(rèn)值或者空，這樣流程更為標(biāo)準(zhǔn)。
分享閱讀：Spring Boot 學(xué)習(xí)筆記。
public void returnObject(final T obj) {
? ? final PooledObject<T> p = allObjects.get(new IdentityWrapper<>(obj));
? ? ? ? //....
? ? //校驗(yàn)失敗直接銷毀 return
? ? ? ? ? ? //...
? ? try {
? ? ? ? factory.passivateObject(p);
? ? } catch (final Exception e1) {
? ? ? ? swallowException(e1);
? ? ? ? try {
? ? ? ? ? ? destroy(p, DestroyMode.NORMAL);
? ? ? ? } catch (final Exception e) {
? ? ? ? ? ? swallowException(e);
? ? ? ? }
? ? ? ? try {
? ? ? ? ? ? ensureIdle(1, false);
? ? ? ? } catch (final Exception e) {
? ? ? ? ? ? swallowException(e);
? ? ? ? }
? ? ? ? updateStatsReturn(activeTime);
? ? ? ? return;
? ? }
? ? ? ? //......
? ? ? ? //返回空閑隊(duì)列
}
對(duì)象池相關(guān)配置項(xiàng)
對(duì)象池提供了許多配置項(xiàng)，在我們使用的GenericObjectPool默認(rèn)基礎(chǔ)對(duì)象池中可以通過構(gòu)造方法傳參傳入GenericObjectPoolConfig，當(dāng)然我們也可以看GenericObjectPoolConfig底層實(shí)現(xiàn)的基礎(chǔ)類BaseObjectPoolConfig，具體包含如下配置:
maxTotal：對(duì)象池中最大使用數(shù)量，默認(rèn)為8
maxIdle：對(duì)象中空閑對(duì)象最大數(shù)量，默認(rèn)為8
minIdle：對(duì)象池中空閑對(duì)象最小數(shù)量，默認(rèn)為8
lifo：當(dāng)去獲取對(duì)象池中的空閑實(shí)例時(shí)，是否需要遵循后進(jìn)先出的原則，默認(rèn)為true
blockWhenExhausted：當(dāng)對(duì)象池處于exhausted狀態(tài)，即可用實(shí)例為空時(shí)，是否阻塞來獲取實(shí)例的線程，默認(rèn)true
fairness：當(dāng)對(duì)象池處于exhausted狀態(tài)，即可用實(shí)例為空時(shí)，大量線程在同時(shí)阻塞等待獲取可用的實(shí)例，fairness配置來控制是否啟用公平鎖算法，即先到先得，默認(rèn)為false。這一項(xiàng)的前提是blockWhenExhausted配置為true
maxWaitMillis：最大阻塞時(shí)間，當(dāng)對(duì)象池處于exhausted狀態(tài)，即可用實(shí)例為空時(shí)，大量線程在同時(shí)阻塞等待獲取可用的實(shí)例，如果阻塞時(shí)間超過了maxWaitMillis將會(huì)拋出異常。當(dāng)此值為負(fù)數(shù)時(shí)，代表無限期阻塞直到可用。默認(rèn)為-1
testOnCreate：創(chuàng)建對(duì)象前是否校驗(yàn)（即調(diào)用工廠的validateObject()方法），如果檢驗(yàn)失敗，那么borrowObject()返回將失敗，默認(rèn)為false
testOnBorrow：取用對(duì)象前是否檢驗(yàn)，默認(rèn)為false
testOnReturn：返回對(duì)象池前是否檢驗(yàn)，即調(diào)用工廠的returnObject()，若檢驗(yàn)失敗會(huì)銷毀對(duì)象而不是返回池中，默認(rèn)為false
timeBetweenEvictionRunsMillis：驅(qū)逐周期，默認(rèn)為-1代表不進(jìn)行驅(qū)逐測(cè)試
testWhileIdle：處于idle隊(duì)列中即閑置的對(duì)象是否被驅(qū)逐器進(jìn)行驅(qū)逐驗(yàn)證，當(dāng)該對(duì)象上次運(yùn)行時(shí)間距當(dāng)前超過了setTimeBetweenEvictionRunsMillis(long))設(shè)置的值，將會(huì)被驅(qū)逐驗(yàn)證，調(diào)用validateObject()方法，若驗(yàn)證成功，對(duì)象將會(huì)銷毀。默認(rèn)為false
使用步驟
創(chuàng)建工廠類：通過繼承BaseGenericObjectPool或者實(shí)現(xiàn)基礎(chǔ)接口PooledObjectFactory,并按照業(yè)務(wù)需求重寫對(duì)象的創(chuàng)建、銷毀、校驗(yàn)、激活、鈍化方法，其中銷毀多為連接的關(guān)閉、置空等。
創(chuàng)建池：通過繼承GenericObjectPool或者實(shí)現(xiàn)基礎(chǔ)接口ObjectPool，建議使用前者，它為我們提供了空閑對(duì)象驅(qū)逐檢測(cè)機(jī)制（即將空閑隊(duì)列中長時(shí)間未使用的對(duì)象銷毀，降低內(nèi)存占用），以及提供了很多對(duì)象的基本信息，例如對(duì)象最后被使用的時(shí)間、使用對(duì)象前是否檢驗(yàn)等。
創(chuàng)建池相關(guān)配置（可選）：通過繼承GenericObjectPoolConfig或者繼承BaseObjectPoolConfig，來增加對(duì)線程池的配置控制，建議使用前者，它為我們實(shí)現(xiàn)了基本方法，只需要自己添加需要的屬性即可。
創(chuàng)建包裝類（可選）：即要存在于對(duì)象池中的對(duì)象，在實(shí)際對(duì)象之外添加許多基礎(chǔ)屬性，便于了解對(duì)象池中對(duì)象的實(shí)時(shí)狀態(tài)。
注意事項(xiàng)
我們雖然使用了默認(rèn)實(shí)現(xiàn)，但是也應(yīng)該結(jié)合實(shí)際生產(chǎn)情況進(jìn)行優(yōu)化，不能使用了線程池而性能卻更低了。另外，Java 系列面試題和答案全部整理好了，微信搜索Java技術(shù)棧，在后臺(tái)發(fā)送：面試，可以在線閱讀。
在使用中我們應(yīng)注意以下事項(xiàng)：
要為對(duì)象池設(shè)置空閑隊(duì)列最大最小值，默認(rèn)最大最小值，默認(rèn)最大為8往往不能滿足需要
private volatile int maxIdle = GenericObjectPoolConfig.DEFAULT_MAX_IDLE;
private volatile int minIdle = GenericObjectPoolConfig.DEFAULT_MIN_IDLE;
public static final int DEFAULT_MAX_IDLE = 8;
public static final int DEFAULT_MIN_IDLE = 0;
對(duì)象池設(shè)置maxWaitMillis屬性，即取用對(duì)象最大等待時(shí)間
使用完對(duì)象及時(shí)釋放對(duì)象，將對(duì)象返回池中，特別是發(fā)生了異常也要通過try..chatch..finally的方式確保釋放，避免占用資源
我們展開講講注意事項(xiàng)，首先為什么要設(shè)置maxWaitMillis，我們?nèi)∮脤?duì)象使用的如下方法
public T borrowObject() throws Exception {
? ? return borrowObject(getMaxWaitMillis());
}
可以看到默認(rèn)的最大等待時(shí)間為-1L
private volatile long maxWaitMillis =
? ? BaseObjectPoolConfig.DEFAULT_MAX_WAIT_MILLIS;
//....
public static final long DEFAULT_MAX_WAIT_MILLIS = -1L;
我們?cè)賮聿榭慈∮脤?duì)象邏輯,blockWhenExhausted默認(rèn)為true，意思是當(dāng)池中不存在空閑對(duì)象時(shí)，又來取用對(duì)象，線程將會(huì)被阻塞直到有新的可用對(duì)象。從上我們得知-1L將會(huì)執(zhí)行idleObjects.takeFirst()
public T borrowObject(final long borrowMaxWaitMillis) throws Exception {
? ? //.......
? ? final boolean blockWhenExhausted = getBlockWhenExhausted();
? ? boolean create;
? ? final long waitTime = System.currentTimeMillis();
? ? while (p == null) {
? ? ? //.......
? ? ? ? if (blockWhenExhausted) {
? ? ? ? ? ? if (p == null) {
? ? ? ? ? ? ? ? if (borrowMaxWaitMillis < 0) {
? ? ? ? ? ? ? ? ? ? p = idleObjects.takeFirst();
? ? ? ? ? ? ? ? } else {
? ? ? ? ? ? ? ? ? ? p = idleObjects.pollFirst(borrowMaxWaitMillis,
? ? ? ? ? ? ? ? ? ? ? ? ? ? TimeUnit.MILLISECONDS);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? }
}
如下，阻塞隊(duì)列將會(huì)一直阻塞，直到有了空閑對(duì)象才停止阻塞，這樣的設(shè)定將會(huì)在吞吐提高時(shí)造成大面積阻塞影響
public E takeFirst() throws InterruptedException {
? ? lock.lock();
? ? try {
? ? ? ? E x;
? ? ? ? while ( (x = unlinkFirst()) == null) {
? ? ? ? ? ? notEmpty.await();
? ? ? ? }
? ? ? ? return x;
? ? } finally {
? ? ? ? lock.unlock();
? ? }
}
還有一個(gè)注意事項(xiàng)就是要記得回收資源，即調(diào)用public void returnObject(final T obj)方法，原因顯而易見，對(duì)象池對(duì)我們是否使用完了對(duì)象是無感知的，需要我們調(diào)用該方法回收對(duì)象，特別是發(fā)生異常也要保證回收，因此最佳實(shí)踐如下：
try{
? item = pool.borrowObject();
} catch(Exception e) {
? log.error("....");
} finally {
? pool.returnObject(item);
}
實(shí)例使用
實(shí)例1：實(shí)現(xiàn)一個(gè)簡(jiǎn)單的字符串池
創(chuàng)建字符串工廠
推薦一個(gè) Spring Boot 基礎(chǔ)教程及實(shí)戰(zhàn)示例：https://www.javastack.cn/categories/Spring-Boot/
package com.anqi.demo.demopool2.pool.fac;
import org.apache.commons.pool2.BasePooledObjectFactory;
import org.apache.commons.pool2.PooledObject;
import org.apache.commons.pool2.impl.DefaultPooledObject;
/**
* 字符串池工廠
*/
public class StringPoolFac extends BasePooledObjectFactory<String> {
? ? public StringPoolFac() {
? ? ? ? super();
? ? }
? ? @Override
? ? public String create() throws Exception {
? ? ? ? return "str-val-";
? ? }
? ? @Override
? ? public PooledObject<String> wrap(String s) {
? ? ? ? return new DefaultPooledObject<>(s);
? ? }
? ? @Override
? ? public void destroyObject(PooledObject<String> p) throws Exception {
? ? }
? ? @Override
? ? public boolean validateObject(PooledObject<String> p) {
? ? ? ? return super.validateObject(p);
? ? }
? ? @Override
? ? public void activateObject(PooledObject<String> p) throws Exception {
? ? ? ? super.activateObject(p);
? ? }
? ? @Override
? ? public void passivateObject(PooledObject<String> p) throws Exception {
? ? ? ? super.passivateObject(p);
? ? }
}
創(chuàng)建字符串池
package com.anqi.demo.demopool2.pool;
import org.apache.commons.pool2.PooledObjectFactory;
import org.apache.commons.pool2.impl.GenericObjectPool;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
/**
* 字符串池
*/
public class StringPool extends GenericObjectPool<String> {
? ? public StringPool(PooledObjectFactory<String> factory) {
? ? ? ? super(factory);
? ? }
? ? public StringPool(PooledObjectFactory<String> factory, GenericObjectPoolConfig<String> config) {
? ? ? ? super(factory, config);
? ? }
}
測(cè)試主類
首先我們我們?cè)O(shè)置setMaxTotal為2，即最多有兩個(gè)對(duì)象被取出使用，設(shè)置setMaxWaitMillis為3S，即最多被阻塞3S，我們循環(huán)取用3次，并不釋放資源。另外，關(guān)注公眾號(hào)Java技術(shù)棧，在后臺(tái)回復(fù)：面試，可以獲取我整理的 Java 系列面試題和答案，非常齊全。
import com.anqi.demo.demopool2.pool.fac.StringPoolFac;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class StringPoolTest {
? ? private static final Logger LOG = LoggerFactory.getLogger(StringPoolTest.class);
? ? public static void main(String[] args) {
? ? ? ? StringPoolFac fac = new StringPoolFac();
? ? ? ? GenericObjectPoolConfig<String> config = new GenericObjectPoolConfig<>();
? ? ? ? config.setMaxTotal(2);
? ? ? ? config.setMinIdle(1);
? ? ? ? config.setMaxWaitMillis(3000);
? ? ? ? StringPool pool = new StringPool(fac, config);
? ? ? ? for (int i = 0; i < 3; i++) {
? ? ? ? ? ? String s = "";
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? s = pool.borrowObject();
? ? ? ? ? ? ? ? LOG.info("str:{}", s);
? ? ? ? ? ? } catch (Exception e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? } finally {
//? ? ? ? ? ? ? ? if (!s.equals("")) {
//? ? ? ? ? ? ? ? ? ? pool.returnObject(s);
//? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? }
}
結(jié)果如下,在兩次成功調(diào)用之后，阻塞3S，接著程序報(bào)錯(cuò)停止。這是因?yàn)榭捎觅Y源最多為2，若不釋放將會(huì)無資源可用，新來的調(diào)用者會(huì)被阻塞3S，之后報(bào)錯(cuò)取用失敗。
16:18:42.499 [main] INFO com.anqi.demo.demopool2.pool.StringPoolTest - str:str-val-
16:18:42.505 [main] INFO com.anqi.demo.demopool2.pool.StringPoolTest - str:str-val-
java.util.NoSuchElementException: Timeout waiting for idle object
我們放開注釋，釋放資源后得到正常執(zhí)行結(jié)果
16:20:52.384 [main] INFO com.anqi.demo.demopool2.pool.StringPoolTest - str:str-val-
16:20:52.388 [main] INFO com.anqi.demo.demopool2.pool.StringPoolTest - str:str-val-
16:20:52.388 [main] INFO com.anqi.demo.demopool2.pool.StringPoolTest - str:str-val-
