Rooba
/
drogon
mirror of https://github.com/drogonframework/drogon.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Modify the DbClientImpl class

This commit is contained in:
antao 2019-01-09 13:12:07 +08:00
parent ac90c80710
commit e1b873ba01
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
orm_lib/src/DbClientImpl.cc
View File

@ -51,13 +51,15 @@ DbClientImpl::DbClientImpl(const std::string &connInfo, const size_t connNum, Cl
//LOG_DEBUG << _loops.getLoopNum();
assert(connNum > 0);
_loops.start();
for (size_t i = 0; i < _connectNum; i++)
{
auto loop = _loops.getNextLoop();
loop->runInLoop([this, loop]() {
_connections.insert(newConnection(loop));
});
}
std::thread([this]() {
for (size_t i = 0; i < _connectNum; i++)
{
auto loop = _loops.getNextLoop();
loop->runInLoop([this, loop]() {
_connections.insert(newConnection(loop));
});
}
}).detach();
}
DbClientImpl::~DbClientImpl() noexcept