对象池化技术(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);//等待时间10000
		
		for(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判定为已失效的对象。