test/drogon
1
0
Fork 0
mirror of https://gitee.com/an-tao/drogon.git synced 2024-11-30 10:47:40 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Fix an error when constructing RedisClientImpl objects (#840)

Browse Source
This commit is contained in:
An Tao 2021-05-05 09:51:04 +08:00 committed by GitHub
parent cb1876f26b
commit f99c72bd5b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
nosql_lib/redis/src/RedisClientImpl.cc
View File

@ -38,14 +38,17 @@ RedisClientImpl::RedisClientImpl(const trantor::InetAddress &serverAddress,
numberOfConnections_(numberOfConnections)
{
loops_.start();
for (size_t i = 0; i < numberOfConnections_; ++i)
{
auto loop = loops_.getNextLoop();
loop->queueInLoop([this, loop]() {
std::lock_guard<std::mutex> lock(connectionsMutex_);
connections_.insert(newConnection(loop));
});
}
std::thread([this]() {
for (size_t i = 0; i < numberOfConnections_; ++i)
{
auto loop = loops_.getNextLoop();
loop->queueInLoop([this, loop]() {
std::lock_guard<std::mutex> lock(connectionsMutex_);
connections_.insert(newConnection(loop));
});
}
}).detach();
}
RedisConnectionPtr RedisClientImpl::newConnection(trantor::EventLoop *loop)
@ -395,4 +398,4 @@ void RedisClientImpl::execCommandAsyncWithTimeout(
tasks_.emplace_back(bfCbPtr);
}
timeoutFlagPtr->runTimer();
}
}