factorymangethread.java

此为连接池实现程序

/**
 * @author 肖建军
 * 连接池调度线程
 */

package com.sunrise.chnl.sql;

public class FactoryMangeThread implements Runnable {
  ConnectionFactory cf = null;
  long delay = 10000; //每1秒钟刷新一次

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

  public void run() {
    while(true){
      try{
        Thread.sleep(delay);
      }   catch(InterruptedException e){}
      //判断是否已经关闭了工厂，那就退出监听
      if (cf.isCreate()) cf.schedule();
      else System.exit(1);
    }
  }
}