ConnectionPool类 参考

ConnectionPool 的协作图:

结构体
class	connectorMgr

Public 成员函数

包函数

包属性

静态包属性

详细描述

在文件 xsql.xcs 第 26 行定义.

成员函数说明

allocate()

Connection allocate ( )

package

在文件 xsql.xcs 第 44 行定义.

                             {
            Connection connector = callback.createConnection();
            if (connector != nilptr){
                _active_cnt++;
            }
            return connector;
        }

clear()

void clear

(

)

在文件 xsql.xcs 第 194 行定义.

                           {
            synchronized(_pool){
                _pool.clear();
                _error_map.clear();
                _wait_time = 0;
                _maxConnect = 0;
                _maxIdle = 0;
                _active_cnt = 0;
                _maxIdleTime = TIMEOU_LIMIT;
            }
        }

config()

bool config	(	ConnPoolCallback	_callback,
		String	reset_error,
		int	maxWait,
		int	maxConnect,
		int	maxIdle,
		int	maxIdleTime,
		int	validtesttime
	)

配置线程池:

参数

_callback	回调
reset_error	当出现这些错误时 并不关闭连接 "2003,2013"
maxWait	最大等待数
maxConnect	最大连接数
maxIdle	最大空闲数
maxIdleTime	最大空闲时间
validtesttime	校验时间

在文件 xsql.xcs 第 159 行定义.

                                                                                                                                                        {
        
            if (maxIdle != 0 && maxConnect != 0 && maxIdle >= maxConnect){
                throw new IllegalArgumentException("Connector config failed : maxIdle >= maxConnect\n");
                return false;
            }
 
            if (_callback == nilptr){
                return false;
            }
            
            callback = _callback;
            
            _validtesttime = validtesttime;
 
            if (reset_error != nilptr){
                String err_list = reset_error;
                String[] elist = err_list.split(',');
                for (int i = 0; i < elist.length; i++){
                    String str = elist[i];
                    str.trim(true);
                    _error_map.put(str.parseInt(), true);
                }
            }
 
            if (maxWait != -1){
                _wait_time = maxWait;
            }
 
            _maxIdle = maxIdle;
            _maxConnect = maxConnect;
            _maxIdleTime = maxIdleTime;
            return true;
        }

引用了 String.length(), String.parseInt(), String.split() , 以及 String.trim().

函数调用图:

getConnector()

Connection getConnector

(

)

在文件 xsql.xcs 第 52 行定义.

                                        {
            Connection connector = nilptr;
            long lastactive = 0;
 
            synchronized(_pool){
                if (_maxConnect != 0){
                    while ((_pool.size() == 0) && (_active_cnt >= _maxConnect)){
                        _pool.wait();
                    }
                }
 
                do{
                    if (connector != nilptr){
                        _active_cnt--;
                        connector.close();
                        connector = nilptr;
                    }
                    
                    lastactive = 0;
 
                    List.Iterator<connectorMgr> iter = _pool.iterator();
                    if (iter.hasNext()){
                        connectorMgr mgr = iter.get();
                        connector = mgr.pconnection;
                        lastactive = mgr.timestamp;
                        _pool.remove(iter);
                    }else{
                        break;
                    }
 
                } while (test(connector, lastactive) == false);
 
                if (connector == nilptr){
                    if ((_maxConnect == 0) || (_active_cnt < _maxConnect)){
                        connector = allocate();
                    }
                }
            }
            return connector;
        }

recycle()

void recycle

(

Connection

connection

)

在文件 xsql.xcs 第 100 行定义.

                                                  {
        
            int mysql_error = connection.getErrorCode();
 
            if (_error_map.containsKey(mysql_error) == false){
                synchronized(_pool){
                    connectorMgr mgr = new connectorMgr();
                    mgr.pconnection = connection;
                    mgr.timestamp = _system_.currentTimeMillis();
 
                    if (_maxIdleTime != 0){
                        List.Iterator<connectorMgr> it = _pool.iterator();
 
                        while (it != nilptr && it.hasNext()){
                            List.Iterator<connectorMgr> tmp = it.getNext();
                            connectorMgr pmt = it.get();
                            
                            if ((mgr.timestamp - pmt.timestamp) > _maxIdleTime){
                                pmt.pconnection.close();
                                _pool.remove(it);
                                _active_cnt--;
                            }
                            it = tmp;
                        }
                    }
 
                    
 
                    if (_maxIdle != 0){
                        while (_pool.size() > _maxIdle){
                            List.Iterator<connectorMgr> tmp = _pool.iterator();
                            connectorMgr pmt = tmp.get();
                            pmt.pconnection.close();
                            _pool.remove(tmp);
                            _active_cnt--;
                        }
                    }
                    _pool.add(mgr);
                    _pool.notify();
                }
            } else{
                connection.close();
                synchronized(_pool){
                    _active_cnt--;
                }
            }
        }

引用了 _system_.currentTimeMillis().

函数调用图:

test()

bool test ( Connection  conn, long  lastactive  )

package

在文件 xsql.xcs 第 93 行定义.

                                                   {
            if ( (_system_.currentTimeMillis() - lastactive) > _validtesttime){
                return callback.alive(conn);
            }
            return true;
        }

引用了 _system_.currentTimeMillis().

函数调用图:

结构体成员变量说明

_active_cnt

int _active_cnt

package

在文件 xsql.xcs 第 38 行定义.

_error_map

Map<int, bool> _error_map = new Map<int, bool>()

package

在文件 xsql.xcs 第 33 行定义.

_maxConnect

int _maxConnect

package

在文件 xsql.xcs 第 37 行定义.

_maxIdle

int _maxIdle

package

在文件 xsql.xcs 第 39 行定义.

_maxIdleTime

int _maxIdleTime

package

在文件 xsql.xcs 第 39 行定义.

_pool

List<connectorMgr> _pool = new List<connectorMgr>()

package

在文件 xsql.xcs 第 32 行定义.

_validtesttime

int _validtesttime

package

在文件 xsql.xcs 第 39 行定义.

_wait_time

int _wait_time

package

在文件 xsql.xcs 第 38 行定义.

callback

ConnPoolCallback callback

package

在文件 xsql.xcs 第 41 行定义.

TIMEOU_LIMIT

const int TIMEOU_LIMIT = 300000

staticpackage

在文件 xsql.xcs 第 35 行定义.