mmlpoolmanager.java.svn-base

java实现的socket连接池,使用了apache的objectpool

// $dateCreated:2006-8-20-11:46:36 userCreated:pippo
package com.vms.ts.simulator.mmlserver;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.PoolableObjectFactory;
import org.apache.commons.pool.impl.GenericObjectPool;
import org.quickserver.net.server.PoolManager;
import org.quickserver.net.server.impl.BasicPoolManager;
import org.quickserver.util.xmlreader.PoolConfig;

/**
 * @author pippo
 */
public class MMLPoolManager extends BasicPoolManager implements PoolManager {

    private static Log logger = LogFactory.getLog(MMLPoolManager.class);

    /*
     * （非 Javadoc）
     *
     * @see org.quickserver.net.server.PoolManager#makeClientHandlerPool(org.apache.commons.pool.PoolableObjectFactory,
     *      org.quickserver.util.xmlreader.PoolConfig)
     */
    public ObjectPool makeClientHandlerPool(PoolableObjectFactory factory, PoolConfig opConfig) {
        if (logger.isDebugEnabled())
            logger.debug("make new clientHandler pool");
        GenericObjectPool.Config bconfig = new GenericObjectPool.Config();
        bconfig.maxActive = opConfig.getMaxActive();
        bconfig.maxIdle = opConfig.getMaxIdle();
        bconfig.testOnReturn = true;
        bconfig.whenExhaustedAction = GenericObjectPool.WHEN_EXHAUSTED_FAIL;
        PoolableObjectFactory _factory = new MMLClientHandlerFactory();
        return new GenericObjectPool(_factory, bconfig);
    }

}