PoolKeeper.java

package org.objectweb.jonas.dbm;
import org.objectweb.jonas.common.Log;
import org.objectweb.util.monolog.api.Logger;
import org.objectweb.util.monolog.api.BasicLevel;

public class PoolKeeper extends Thread {

    private Pool pool;
    private Logger logger = null;
    private long adjustperiod = 15000L;  // default = 15s
    private long samplingperiod = 60000L;  // default = 60s

    public PoolKeeper(Pool pool) {
        super("PoolKeeper");
        setDaemon(true);
        this.pool = pool;
        logger = Log.getLogger(Log.JONAS_DBM_PREFIX);
    }

    public void setSamplingPeriod(int sec) {
        logger.log(BasicLevel.DEBUG, " to " + sec);
        samplingperiod = sec * 1000L;
    }

    public void run() {
        long timeout;
        long adjusttime = adjustperiod;
        long samplingtime = samplingperiod;
        while (true) {
            timeout = adjusttime;
            if (samplingtime < timeout) {
                timeout = samplingtime;
            }
            try {
                sleep(timeout);
                adjusttime -= timeout;
                samplingtime -= timeout;
                if (adjusttime <= 0) {
                    pool.adjust();
                    adjusttime = adjustperiod;
                }
                if (samplingtime <= 0) {
                    pool.sampling();
                    samplingtime = samplingperiod;
                }
            } catch (NullPointerException e) {
                logger.log(BasicLevel.ERROR, "poolkeeper NPE:" + e);
                e.printStackTrace();
            } catch (Exception e) {
                logger.log(BasicLevel.ERROR, "poolkeeper error:" + e);
                e.printStackTrace();
            }
        }
    }
}

---