add testcase & bug fixed

This commit is contained in:
wenshao
2012-08-25 10:40:45 +08:00
parent 6ee9986cfe
commit 6f864243bc
8 changed files with 535 additions and 7 deletions
@@ -416,13 +416,8 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
connectError = ex;
}
createConnectionThread = new CreateConnectionThread("Druid-ConnectionPool-Create");
createConnectionThread.setDaemon(true);
destoryConnectionThread = new DestroyConnectionThread("Druid-ConnectionPool-Destory");
destoryConnectionThread.setDaemon(true);
createConnectionThread.start();
destoryConnectionThread.start();
createAndStartCreatorThread();
createAndStartDestroyThread();
initedLatch.await();
@@ -448,6 +443,16 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
}
}
private void createAndStartDestroyThread() {
DestroyConnectionThread thread = new DestroyConnectionThread("Druid-ConnectionPool-Destory");
thread.start();
}
protected void createAndStartCreatorThread() {
CreateConnectionThread thread = new CreateConnectionThread("Druid-ConnectionPool-Create");
thread.start();
}
private void loadFilterFromSystemProperty() throws SQLException {
String property = System.getProperty("druid.filters");
@@ -1129,6 +1134,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
public CreateConnectionThread(String name){
super(name);
this.setDaemon(true);
}
public void run() {
@@ -1222,6 +1228,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
public DestroyConnectionThread(String name){
super(name);
this.setDaemon(true);
}
public void run() {