commonspoolfactory.java

来自「一个非常好的FRAMWRK!是一个外国组织做的!不!」· Java 代码 · 共 85 行

/**
 * Copyright 2003-2005 the original author or authors.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at

       http://www.apache.org/licenses/LICENSE-2.0

 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.jdon.controller.pool;
import org.apache.commons.pool.PoolableObjectFactory;
import org.apache.commons.pool.impl.GenericObjectPool;

import com.jdon.bussinessproxy.TargetMetaDef;
import com.jdon.bussinessproxy.target.TargetServiceFactory;
import com.jdon.util.Debug;

public class CommonsPoolFactory implements PoolableObjectFactory {
    private final static String module = CommonsPoolFactory.class.getName();
    
    private TargetServiceFactory targetServiceFactory;
    private TargetMetaDef targetMetaDef;
    private CommonsPoolAdapter pool;
    
    /**
     * @param targetServiceFactory
     */
    public CommonsPoolFactory(TargetServiceFactory targetServiceFactory,
                              TargetMetaDef targetMetaDef,
                              String maxSize) {
        super();
        this.targetServiceFactory = targetServiceFactory;
        this.targetMetaDef = targetMetaDef;
        
    		GenericObjectPool apachePool = new GenericObjectPool(this);
    		pool = new CommonsPoolAdapter(apachePool);
    		if (maxSize == null){
    		    Debug.logError(" not set pool's max size", module);
    		}else{
    		    int maxInt = Integer.parseInt(maxSize);
    		    pool.setMaxPoolSize(maxInt);
    		}
    }
    
    
    /**
     * @return Returns the pool.
     */
    public CommonsPoolAdapter getPool() {
        return pool;
    }
            

    public Object makeObject() {
        Object o = null;        
        try {
            o =  targetServiceFactory.create(targetMetaDef);
        } catch (Exception ex) {
            Debug.logError(" Pool can not make object, error: " + ex , module);
        }
        return o;
    }

    public void destroyObject(Object o) throws Exception {
        targetServiceFactory.destroy(targetMetaDef);
    }

    public void activateObject(Object o) throws Exception {
    }

    public void passivateObject(Object o) throws Exception {
    }

    public boolean validateObject(Object o) {
        return true;
    }

}