coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2025-12-08 01:36:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

outcomment debug logs

Browse Source
This commit is contained in:
Denis Blank 2015-07-16 22:42:56 +02:00 committed by Naios
parent 174271a6e7
commit e25a268eb9
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
test.cpp
View File

@ -303,7 +303,7 @@ public:
if (_queue.try_dequeue(token, callable))
{
std::string msg = "Thread " + std::to_string(i) + " is dispatching...\n";
std::cout << msg;
// std::cout << msg;
callable();
}
else
@ -313,7 +313,7 @@ public:
{
std::string msg = "Thread " + std::to_string(i) + " out of work...\n";
std::cout << msg;
// std::cout << msg;
}
std::unique_lock<std::mutex> lock(_mutex);
@ -323,7 +323,7 @@ public:
{
std::string msg = "Thread " + std::to_string(i) + " wakes up...\n";
std::cout << msg;
// std::cout << msg;
}
}
}
@ -709,7 +709,7 @@ int main(int /*argc*/, char** /*argv*/)
{
// std::this_thread::sleep_for(std::chrono::milliseconds(wait));
std::string str = "Pass " + std::to_string(run) + " dispatching " + std::to_string(i) + " (" + std::to_string(wait) + "ms delay)" + "\n";
std::cout << str;
// std::cout << str;
countPool.Dispatch([&container, wait]
{
@ -721,11 +721,11 @@ int main(int /*argc*/, char** /*argv*/)
std::this_thread::sleep_for(std::chrono::milliseconds(50));
}
std::cout << "Awaiting termination...\n";
// std::cout << "Awaiting termination...\n";
// std::this_thread::sleep_for(std::chrono::seconds(5));
std::this_thread::sleep_for(std::chrono::seconds(5));
// std::this_thread::sleep_for(std::chrono::seconds(5));
pool.Await();
countPool.Await();