使用blockingqueue可简单实现线程安全的对象池，通过take()和offer()保证并发访问的正确性；若需复杂控制逻辑，可用reentrantlock手动加锁管理对象状态；推荐在生产环境中使用apache commons pool，其提供完整的对象生命周期管理和配置选项，确保高并发下的稳定性和可维护性。
在Java中实现线程安全的对象池，核心是确保多个线程并发获取和归还对象时不会出现状态错误或资源竞争。常见做法是结合同步机制与线程安全的数据结构来管理对象的复用。
使用BlockingQueue实现线程安全的对象池
最简单有效的方式是使用java.util.concurrent.BlockingQueue作为对象存储容器，它本身是线程安全的，并支持阻塞式获取操作。
示例：创建一个可复用的Runnable任务对象池
public class ObjectPool<T> {
private final BlockingQueue<T> pool;
<pre class='brush:java;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);
}
}}
立即学习“Java免费学习笔记（深入）”；
说明：
- ArrayBlockingQueue 是有界阻塞队列，构造时指定容量，自动保证线程安全。
- borrowObject() 使用 take() 方法，若池中无对象则线程等待。
- returnObject() 使用 offer() 将对象放回池中，安全且高效。
使用synchronized或Lock保护自定义池逻辑
如果需要更复杂的控制逻辑（如对象状态校验、超时创建等），可以手动加锁。
public class CustomObjectPool<T> {
private final List<T> available = new ArrayList<>();
private final List<T> borrowed = new ArrayList<>();
<pre class='brush:java;toolbar:false;'>private final Lock lock = new ReentrantLock();
public T borrow() {
lock.lock();
try {
if (available.isEmpty()) {
return null; // 或抛异常 / 创建新实例
}
T obj = available.remove(available.size() - 1);
borrowed.add(obj);
return obj;
} finally {
lock.unlock();
}
}
public void release(T obj) {
lock.lock();
try {
borrowed.remove(obj);
available.add(obj);
} finally {
lock.unlock();
}
}}
立即学习“Java免费学习笔记（深入）”；
优点：
- 可扩展性强，便于加入对象初始化、验证、销毁逻辑。
- 配合条件变量（Condition）还能实现等待/唤醒机制。
推荐使用已有成熟库：Apache Commons Pool
实际项目中建议使用Apache Commons Pool库，它提供了完整的对象池管理功能，包括：
- 对象工厂（PooledObjectFactory）定义生命周期方法。
- 支持最大空闲数、最小空闲数、借用超时等配置。
- 内置线程安全实现。
示例：
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>基本上就这些。选择哪种方式取决于需求复杂度：简单场景用BlockingQueue即可，复杂场景推荐Apache Commons Pool。关键是确保所有共享状态的操作都受到同步保护。
