public class ObjectPool<T> {
    private final BlockingQueue<T> pool;
<pre class='brush:j*a;toolbar:false;'>public ObjectPool(Queue<T> sourceList) {
    this.pool = new ArrayBlockingQueue<>(sourceList.size());
    pool.addAll(sourceList);
}

// 获取对象（阻塞直到有可用对象）
public T borrowObject() throws InterruptedException {
    return pool.take();
}

// 归还对象
public void returnObject(T obj) {
    if (obj != null) {
        pool.offer(obj);
    }
}

}

public class CustomObjectPool<T> {
    private final List<T> *ailable = new ArrayList<>();
    private final List<T> borrowed = new ArrayList<>();
<pre class='brush:j*a;toolbar:false;'>private final Lock lock = new ReentrantLock();

public T borrow() {
    lock.lock();
    try {
        if (*ailable.isEmpty()) {
            return null; // 或抛异常 / 创建新实例
        }
        T obj = *ailable.remove(*ailable.size() - 1);
        borrowed.add(obj);
        return obj;
    } finally {
        lock.unlock();
    }
}

public void release(T obj) {
    lock.lock();
    try {
        borrowed.remove(obj);
        *ailable.add(obj);
    } finally {
        lock.unlock();
    }
}

}

GenericObjectPoolConfig<MyResource> config = new GenericObjectPoolConfig<>();
config.setMaxTotal(10);
config.setMaxIdle(5);
<p>PooledObjectFactory<MyResource> factory = new MyResourceFactory();
GenericObjectPool<MyResource> pool = new GenericObjectPool<>(factory, config);</p><p>MyResource res = pool.borrowObject(); // 线程安全获取
try {
// 使用资源
} finally {
pool.returnObject(res); // 归还
}</p>