MYSQL* _conn;         //連接句柄                                  
clock_t _startTime;   //連接起始空閑時(shí)間

Connection();            //構(gòu)造 init Connection
~Connection();           //析構(gòu) destroy connection
bool connect(ip, port, username, password, dbname);     //連接操作， 返回連接結(jié)果
bool update(sql);        //表更新操作, 返回更新結(jié)果 
MYSQL_RES* query(sql);   //查詢操作, 返回查詢結(jié)果
void refreshStartTime(); //刷新連接起始空閑時(shí)間
clock_t getAliveTime();  //獲取連接空閑時(shí)間

//連接登錄信息
string _ip;
unsigned short _port;
string _username;
string _password;
string _dbname;
//連接數(shù)量等配置信息
int _initSize;
int _maxSize;
int _maxIdleTime;
int _connectionTimeout;
//連接存儲(chǔ)信息，以及保證線程安全
queue<Connection*> _connectionQue;
mutex _queueLock;
condition_variable _cond;
atomic_int _connectionCnt;

ConnectionPool();                          //構(gòu)造 init pool, 加載配置, 初始連接, 啟動(dòng)線程
static ConnectionPool* getConnectionPool();//獲取單例
shared_ptr<Connection> getConnection();    //獲取連接
int _loadConfigFile(string& filename);     //加載解析配置信息
void produceConnectionTask();              //生產(chǎn)連接任務(wù)
void scannerConnetionTask();               //掃描監(jiān)視銷毀空閑線程任務(wù)

/*
    從連接池中獲取一條連接. 相當(dāng)于是消費(fèi)者
    消費(fèi)前提, _connectionQue中有貨, 所以無貨期間需要進(jìn)行阻塞休眠等待. 
    等待也不能一直等待. 存在連接超時(shí)時(shí)間, 
    waittime >= _connectionTimeout then output << error.
*/
shared_ptr<Connection> getConnection() {
    unique_lock<mutex> auto_lock(_queueLock);//定義智能鎖
    while (_connectionQue.empty()) {
        if (cv_status::timeout == _cond.wait_for(auto_lock,                                          chrono::milliseconds(_connectionTimeout))) { //達(dá)到連接超時(shí)時(shí)間
            if (_connectionQue.empty()) {
                //LOG DEBUG INFO
                cerr << "獲取連接超時(shí)" << endl;
                return nullptr;
            }
        }
    }
    //定義shared_ptr<Connection> 自定義del函數(shù), 而非直接調(diào)用~T()
    shared_ptr<Connection> sp(_connectionQue.front(), [&](Connection* pconn){
        unique_lock<mutex> auto_lock(_queueLock);
        pconn->refreshStartTime();      //刷新連接起始空閑時(shí)間
        _connectionQue.push(pconn);
    });
    _connectionQue.pop();
    _cond.notify_all();                 //彈出任務(wù), queue maybe empty notify produce
    return sp;
}

/*
    生產(chǎn)者線程任務(wù). 在_connectionQue中無connetion 
    && _connectionCnt < _maxSize 時(shí)候 及時(shí)創(chuàng)建連接填充_connectionQue。                   
*/
void produceConnectionTask() {
    for (;;) {
        unique_lock<mutex> auto_lock(_queueLock);
        while (!_connectionQue.empty()) {
            _cond.wait(auto_lock);
        }
        if (_connectionCnt < _maxSize) {
            Connection* pconn = new Connection();
            pconn->connet(_ip, _port, _username, _password, _dbname);
            pconn->refreshStartTime();
            _connectionQue.push(pconn);
            _connectionCnt++;
        }
        _cond.notify_all(); //通知消費(fèi)
    }
}
?

/*
	不停的掃描所有的connection, 從頭到尾的掃描, 
    監(jiān)控銷毀哪些長期空閑的connection, 避免對(duì)于空閑資源的無端占用浪費(fèi).  
    每一次休眠一個(gè) _maxIdleTime 就出來 檢查, 定期輪詢檢查空閑麗連接進(jìn)行銷毀
*/
void scannerConnectionTask() {
    for (;;) {
        //休眠maxIdleTime
    	this_thread::sleep_for(chrono::seconds(_maxIdleTime));   
        unique_lock<mutex> auto_lock(_queueLock);
        while (_connectionCnt > _initSize)
		{
			Connection *p = _connectionQue.front();
			if (p->getAliveeTime()/SECONDS_PER_SEC >= _maxIdleTime)
			{
				_connectionQue.pop();
				_connectionCnt--;
				delete p; // 調(diào)用~Connection()釋放連接
			}
			else
			{
				break; // 隊(duì)頭的連接沒有超過_maxIdleTime，其它連接肯定沒有
			}
		}       
    }
}