public synchronized int getMaxConnectionNumber()
{
return maxConnections;
}
public int getCurrentConnectionNumber()
{
return availableConnections.size();
}
/*
*总共的连接数(包括已连接的和未被连接的)
*/
public synchronized int totalConnections()
{
return (availableConnections.size() +
busyConnections.size());
}
/*
*通过创建后台线程,来建立与数据库的连接
*原因:有可能通过网络连接数据库比较慢,所以不能直接地在前台建立连接
*/
private void makeBackgroundConnection()
{
connectionPending = true;
try
{
Thread connectThread = new Thread(this);
connectThread.start();
}
catch(OutOfMemoryError oome)
{
// Give up on new connection
}
}
public void run() {
// TODO Auto-generated method stub
Connection connection = null ;
try
{
connection = makeNewConnection();
synchronized(this)
{
availableConnections.addElement(connection);
notifyAll();
}
}
catch(Exception e)
{ // SQLException or OutOfMemory
// Give up on new connection and wait for existing one
// to free up.
e.printStackTrace();
return ;
}finally
{
connectionPending = false;
}
}
分享到:
相关推荐
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用
jar包,官方版本,自测可用