如何实现 Java Object Pool

实现Java对象池需要遵循以下步骤：

1. 创建一个对象池类：

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class ObjectPool<T> {
    private final BlockingQueue<T> pool;
    private final ObjectFactory<T> factory;

    public ObjectPool(int maxPoolSize, ObjectFactory<T> factory) {
        this.factory = factory;
        pool = new ArrayBlockingQueue<>(maxPoolSize);
        initializePool();
    }

    private void initializePool() {
        for (int i = 0; i < maxPoolSize; i++) {
            pool.add(factory.createObject());
        }
    }

    public T borrowObject() throws InterruptedException {
        T object = pool.poll(10, TimeUnit.SECONDS);
        if (object == null) {
            throw new RuntimeException("No available objects in the pool");
        }
        return object;
    }

    public void returnObject(T object) throws InterruptedException {
        if (pool.offer(object, 10, TimeUnit.SECONDS)) {
            return;
        } else {
            throw new RuntimeException("Failed to return object to the pool");
        }
    }
}

2. 创建一个对象工厂接口：

public interface ObjectFactory<T> {
    T createObject();
}

3. 实现对象工厂：

public class MyObjectFactory implements ObjectFactory<MyObject> {
    @Override
    public MyObject createObject() {
        return new MyObject();
    }
}

4. 使用对象池：

public class Main {
    public static void main(String[] args) {
        ObjectPool<MyObject> myObjectPool = new ObjectPool<>(5, new MyObjectFactory());

        try {
            MyObject obj1 = myObjectPool.borrowObject();
            // 使用对象
            myObjectPool.returnObject(obj1);

            MyObject obj2 = myObjectPool.borrowObject();
            // 使用对象
            myObjectPool.returnObject(obj2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

在这个示例中，我们创建了一个泛型对象池ObjectPool，它接受一个最大池大小和一个对象工厂。对象池使用BlockingQueue来存储和管理对象。当需要从池中获取对象时，我们调用borrowObject()方法；当对象不再使用时，我们调用returnObject()方法将其归还给池。如果池中没有可用对象，borrowObject()方法将等待一段时间，然后抛出异常。同样，如果无法将对象归还给池，returnObject()方法也将抛出异常。