日期:2014-05-16  浏览次数:20517 次

几种Java数据库连接池实现(三)<2>
ackage pool;

//连接池调度线程
public class FactoryMangeThread implements Runnable {
    ConnectionFactory cf = null;

    long delay = 1000;

    public FactoryMangeThread(ConnectionFactory obj) {
        cf = obj;
    }

    /*
    * (non-Javadoc)
    *
    * @see java.lang.Runnable#run()
    *
    */
    public void run() {
        while (true) {
            try {
                Thread.sleep(delay);
            } catch (InterruptedException e) {
            }
            System.out.println("eeeee");
            // 判断是否已经关闭了工厂,那就退出监听
            if (cf.isCreate())
                cf.schedule();
            else
                System.exit(1);
        }
    }
}



package pool;

//连接池工厂参数
public class FactoryParam {
    // 最大连接数
    private int MaxConnectionCount = 4;

    // 最小连接数
    private int MinConnectionCount = 2;

    // 回收策略
    private int ManageType = 0;

    public FactoryParam() {
    }

    /**
    *
    * 构造连接池工厂参数的对象
    *
    * @param max
    *            最大连接数
    *
    * @param min
    *            最小连接数
    *
    * @param type
    *            管理策略
    *
    */
    public FactoryParam(int max, int min, int type) {
        this.ManageType = type;
        this.MaxConnectionCount = max;
        this.MinConnectionCount = min;
    }

    /**
    *
    * 设置最大的连接数
    *
    * @param value
    *
    */
    public void setMaxConn(int value) {
        this.MaxConnectionCount = value;
    }

    /**
    *
    * 获取最大连接数
    *
    * @return
    *
    */
    public int getMaxConn() {
        return this.MaxConnectionCount;
    }

    /**
    *
&nbs