您现在的位置：程式碼之家 >> 編程語言 > >> Java 程式設計 >> Java 相關知識

物件池模式 Java 實作：從核心邏輯到生產級管理器

編輯：Java 相關知識

什麼是物件池？

物件池 預先建立並管理一組可重複使用的物件實例。客戶端從池中「借用」物件，用完後「歸還」而非銷毀。適用於：

物件建立/銷毀成本高（資料庫連線、執行緒、大型物件）
頻繁建立但同一時間存活數量有限
需可預測的取得延遲（避免 GC 抖動）

核心角色

Reusable：被池化的物件介面/類別
Client：使用物件的呼叫端
ReusablePool：管理物件生命週期（建立、借出、歸還、銷毀、超時）

單一池核心實作

public class ObjectPool<T> {
    private final Stack<T> pool = new Stack<>();
    private final Class<T> clazz;
    private final PoolConfig config;
    private int createdCount = 0;

    public ObjectPool(Class<T> clazz, PoolConfig config) {
        this.clazz = clazz;
        this.config = config;
        initialize();
    }

    private void initialize() {
        for (int i = 0; i < config.getMinSize(); i++) {
            pool.push(createObject());
        }
    }

    private T createObject() {
        try {
            createdCount++;
            return clazz.getDeclaredConstructor().newInstance();
        } catch (Exception e) {
            throw new RuntimeException("建立物件失敗", e);
        }
    }

    /** 取得物件（阻塞等待） */
    public synchronized T borrowObject(long timeoutMillis) throws InterruptedException {
        long deadline = System.currentTimeMillis() + timeoutMillis;
        while (pool.isEmpty()) {
            if (createdCount < config.getMaxSize()) {
                return createObject();
            }
            long waitTime = deadline - System.currentTimeMillis();
            if (waitTime <= 0) return null; // 超時
            wait(waitTime);
        }
        return pool.pop();
    }

    /** 歸還物件 */
    public synchronized void returnObject(T obj) {
        if (obj == null) return;
        if (clazz.isInstance(obj)) {
            pool.push(obj);
            notifyAll(); // 喚醒等待執行緒
        }
    }

    /** 關閉池，釋放資源 */
    public void close() {
        pool.clear();
    }
}

池配置類別

public class PoolConfig {
    private int minSize = 5;      // 初始/最小閒置數
    private int maxSize = 20;     // 最大物件數
    private long maxWaitMillis = 2000; // 取得超時時間
    private boolean testOnBorrow = true; // 借出前驗證
    // getter/setter 省略
}

池管理器（單例、多池隔離）

public class ObjectPoolManager {
    private static final Map<Class<?>, ObjectPool<?>> pools = new ConcurrentHashMap<>();

    @SuppressWarnings("unchecked")
    public static <T> ObjectPool<T> getPool(Class<T> clazz) {
        return (ObjectPool<T>) pools.computeIfAbsent(clazz, k -> new ObjectPool<>(k, new PoolConfig()));
    }

    @SuppressWarnings("unchecked")
    public static <T> ObjectPool<T> getPool(Class<T> clazz, PoolConfig config) {
        return (ObjectPool<T>) pools.computeIfAbsent(clazz, k -> new ObjectPool<>(k, config));
    }
}

客戶端使用範例

// 取得池
ObjectPool<ExpensiveResource> pool = ObjectPoolManager.getPool(ExpensiveResource.class);

// 借用
ExpensiveResource resource = pool.borrowObject(2000);
if (resource == null) {
    throw new RuntimeException("資源耗盡，等待超時");
}
try {
    resource.doWork(); // 使用資源
} finally {
    // 必須歸還！
    pool.returnObject(resource);
}

生產環境必備增強

功能	實作要點
閒置物件驗證	`testOnBorrow` / `testOnReturn` / `testWhileIdle`，失效則重建
閒置清理執行緒	定期掃描超過 `minIdleTime` 的物件並銷毀，維持池大小
物件重置	歸還前呼叫 `reset()` 清理狀態，避免髒資料洩漏
JMX/監控指標	暴露 `activeCount`、`idleCount`、`borrowCount`、`waitTime` 等指標
公平鎖/非公平鎖	高併發下選擇 `ReentrantLock(true)` 避免飢餓