mirror/oatpp
2
0
Fork 0
mirror of https://github.com/oatpp/oatpp.git synced 2025-04-18 19:00:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

tests: harden PoolTest

Browse Source
This commit is contained in:
lganzzzo 2021-10-29 00:24:57 +03:00
parent cc2e1e98a9
commit 1818b98caa
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
test/oatpp/core/provider/PoolTest.cpp
View File

@ -176,7 +176,7 @@ void PoolTest::onRun() {
oatpp::async::Executor executor(10, 1, 1);
auto provider = std::make_shared<Provider>();
auto pool = Pool::createShared(provider, 10, std::chrono::seconds(1));
auto pool = Pool::createShared(provider, 10, std::chrono::seconds(2));
std::list<std::thread> threads;
@ -187,9 +187,12 @@ void PoolTest::onRun() {
executor.execute<ClientCoroutine>(pool, false);
}
std::this_thread::sleep_for(std::chrono::milliseconds (200));
OATPP_LOGD(TAG, "1) pool->getCounter() == %d", pool->getCounter());
OATPP_ASSERT(pool->getCounter() == 10);
OATPP_LOGD(TAG, "Waiting...");
std::this_thread::sleep_for(std::chrono::seconds(6));
std::this_thread::sleep_for(std::chrono::seconds(10));
OATPP_LOGD(TAG, "Pool counter=%d", pool->getCounter());
OATPP_ASSERT(pool->getCounter() == 0);
@ -199,9 +202,12 @@ void PoolTest::onRun() {
executor.execute<ClientCoroutine>(pool, false);
}
std::this_thread::sleep_for(std::chrono::milliseconds (200));
OATPP_LOGD(TAG, "2) pool->getCounter() == %d", pool->getCounter());
OATPP_ASSERT(pool->getCounter() == 10);
OATPP_LOGD(TAG, "Waiting...");
std::this_thread::sleep_for(std::chrono::seconds(6));
std::this_thread::sleep_for(std::chrono::seconds(10));
OATPP_LOGD(TAG, "Pool counter=%d", pool->getCounter());
OATPP_ASSERT(pool->getCounter() == 0);