3.为什么要使用连接池

pooling是程序启动时建立足够的数据库连接并将这些连接组成

一个连接池由程序

上另一方面也增进了系统运行环境的平稳性减少内存碎片以及数据库临时进程/线程的数

数据库连接池在初始化过程中已经创建了若干数据库连接置于池中备用。

对于业务请求处理而言直接利用现有可用连接避免了从数据库连接初始化和释

在较为完备的数据库连接池实现中可根据预先的连接占用超时设定强制收回被占用连接。

从而

使用完毕之后把连接返回给连接池

需要访问数据库的时候需要从连接池中获取到空闲的连接任务处理完毕后线程

线程池主动操作主动获取任务并执行任务

CResultSet::CResultSet(MYSQL_RES

*res)

mysql_num_fields(m_res);MYSQL_FIELD

*fields

将表头数据存储到m_key_map中m_key_map.insert(make_pair(fields[i].name,

i));}

MySQL连接从连接池中获取到的连接时一个CDBConn对象类型。

class

(!m_mysql){log_error(mysql_init

failed\n);return

配合mysql_ping实现自动重连mysql_options(m_mysql,

utf8mb4);

m_pDBPool-GetPasswrod(),m_pDBPool-GetDBName(),

NULL,

0)){log_error(mysql_real_connect

failed:

m_mutex;std::condition_variable

m_cond_var;bool

ret;}m_free_list.push_back(pDBConn);}//

log_info(db

(int)m_free_list.size());return

9.2

lock(m_mutex);//m_abort_request

{log_warn(have

timeout_ms);m_cond_var.wait(lock,

[this]

m_abort_request被置为true要释放整个连接池m_cond_var.wait_for(lock,

std::chrono::milliseconds(timeout_ms),

[this]

带超时功能时还要判断是否为空if(m_free_list.empty())

{log_warn(have

NULL;}else{m_free_list.push_back(pDBConn);m_db_cur_conn_cnt;//

log_info(new

吐出连接从空闲队列删除m_used_list.push_back(pConn);//将连接存放到被使用的

链表中return

m_free_list.end()){m_used_list.remove(pConn);m_free_list.push_back(pConn);m_cond_var.notify_one();

else

检查与服务端的连接是否正常。

连接断开时如果自动重新连接功能未被禁用则尝试重新连接服务

器。

该函数可被客户端用来检测闲置许久以后与服务端的连接是否关闭如有需要则重新连接。

返回值

连接正常返回0如有错误发生则返回非0值。

返回非0值并不意味着服务器本身关闭掉也有可能

10.

这里只是一个经验公式还要和线程池数量以及业务结合在一起吗根据经验公式的连接数的上下去测试连接池性能瓶颈。

实际分析

如果任务整体上是一个IO密集型的任务。

在处理一个请求的过程中处理一个任务总共耗时

1005105ms而其中只有

5ms是用于计算操作的消耗cpu另外的100ms等待io响应CPU利用

使用线程池是为了尽量提高CPU的利用率减少对CPU资源的浪费假设以100%的CPU利用率来说要

达到100%的CPU利用率对于一个CPU就要设置其利用率的倒数个数的线程数也即

1/(5/(1005))214个CPU的话就乘以4。

那么算下来的话就是……84这个时候线程池要设置84个线