对象池化技术(2)--一个简单的实现(基于apache的commons-pool)

天高云淡

　　这几天没事的时候都在自己写池的通用方法..今天测试了下,性能超差..算了,还是用大牛的吧..要站在巨人肩膀上..
　　import java.util.NoSuchElementException;import java.util.concurrent.TimeUnit;import org.apache.commons.pool.BasePoolableObjectFactory;import org.apache.commons.pool.ObjectPool;import org.apache.commons.pool.impl.GenericObjectPool;/*** 模拟人去澡堂洗澡,衣服柜子有限制(3个),20人要洗澡,只有拿到要是的人才能洗澡* @author qc**/public class WashTest {private static int sequence = 0; static synchronized int getSeqence(){return sequence++;}public static void main(String[] args) {final ObjectPool objectPool = new GenericObjectPool(new BasePoolableObjectFactory(){@Override/** 初始化用到此方法.这里用int举例,实际中用实际的类*/public Object makeObject() throws Exception {Object obj = WashTest.getSeqence();return obj;}},3,GenericObjectPool.DEFAULT_WHEN_EXHAUSTED_ACTION,10000);//等待时间10000for(int i = 0;i < 20;i++){new Thread(new Runnable(){ObjectPool opinner = objectPool;public void run() {while(true){try {Object obj = null;synchronized (opinner) {obj = opinner.borrowObject();}System.out.println(Thread.currentThread().getName()+"拿到了第"+obj.toString()+"把钥匙");System.out.println(Thread.currentThread().getName()+"开始洗澡.");if(obj!=null){synchronized (opinner) {opinner.returnObject(obj);System.out.println(Thread.currentThread().getName()+"归还了第"+obj.toString()+"把钥匙");}}obj = null;//显示释放资源TimeUnit.SECONDS.sleep(5L);} catch (NoSuchElementException e) {e.printStackTrace();} catch (IllegalStateException e) {e.printStackTrace();} catch (Exception e) {e.printStackTrace();}}}}).start();}}}
　　用到commons-pool-1.4
　　运行结果:
　　hread-0拿到了第0把钥匙Thread-2拿到了第1把钥匙Thread-4拿到了第2把钥匙Thread-0开始洗澡.Thread-2开始洗澡.Thread-4开始洗澡.Thread-0归还了第0把钥匙Thread-2归还了第1把钥匙Thread-5拿到了第1把钥匙Thread-5开始洗澡.Thread-7拿到了第0把钥匙Thread-7开始洗澡.Thread-4归还了第2把钥匙Thread-13拿到了第2把钥匙Thread-13开始洗澡.Thread-5归还了第1把钥匙Thread-7归还了第0把钥匙Thread-1拿到了第0把钥匙Thread-1开始洗澡.Thread-3拿到了第1把钥匙Thread-3开始洗澡.Thread-13归还了第2把钥匙Thread-11拿到了第2把钥匙Thread-11开始洗澡.Thread-1归还了第0把钥匙Thread-19拿到了第0把钥匙Thread-19开始洗澡.Thread-3归还了第1把钥匙Thread-6拿到了第1把钥匙Thread-6开始洗澡.Thread-11归还了第2把钥匙...
1.认识PoolableObjectFactory、ObjectPool和ObjectPoolFactory

在Pool组件中，对象池化的工作被划分给了三类对象：

* PoolableObjectFactory用于管理被池化的对象的产生、激活、挂起、校验和销毁；
* ObjectPool用于管理要被池化的对象的借出和归还，并通知PoolableObjectFactory完成相应的工作；
* ObjectPoolFactory则用于大量生成相同类型和设置的ObjectPool。

相应地，使用Pool组件的过程，也大体可以划分成“创立PoolableObjectFactory”、“使用ObjectPool”和可选的“利用ObjectPoolFactory”三种动作。


创立PoolableObjectFactory

Pool组件利用PoolableObjectFactory来照看被池化的对象。ObjectPool的实例在需要处理被池化的对象的产生、激活、挂起、校验和销毁工作时，就会调用跟它关联在一起的PoolableObjectFactory实例的相应方法来操作。

PoolableObjectFactory是在org.apache.commons.pool包中定义的一个接口。实际使用的时候需要利用这个接口的一个具体实现。Pool组件本身没有包含任何一种PoolableObjectFactory实现，需要根据情况自行创立。

实现PoolableObjectFactory接口,要重写一下方法:
1.Object makeObject()方法。这个方法用于每次取得新的实例时调用。
2.void activateObject(Object obj)方法。这个方法用于将对象“激活”――设置为适合开始使用的状态。
3.void passivateObject(Object obj)方法。这个方法用于将对象“挂起”――设置为适合开始休眠的状态。
4.boolean validateObject(Object obj)方法。这个方法用于校验一个具体的对象是否仍然有效，已失效的对象会被自动交给destroyObject方法销毁
5.void destroyObject(Object obj)方法。这个方法用于销毁被validateObject判定为已失效的对象。