coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2026-02-08 18:56:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

outcomment debug logs

Browse Source
This commit is contained in:
Naios 2015-07-16 22:42:56 +02:00
parent e78aef1570
commit 5a009b0da8
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)) if (_queue.try_dequeue(token, callable))
{ {
std::string msg = "Thread " + std::to_string(i) + " is dispatching...\n"; std::string msg = "Thread " + std::to_string(i) + " is dispatching...\n";
std::cout << msg; // std::cout << msg;
callable(); callable();
} }
else else
@ -313,7 +313,7 @@ public:
{ {
std::string msg = "Thread " + std::to_string(i) + " out of work...\n"; 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); std::unique_lock<std::mutex> lock(_mutex);
@ -323,7 +323,7 @@ public:
{ {
std::string msg = "Thread " + std::to_string(i) + " wakes up...\n"; 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::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::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] countPool.Dispatch([&container, wait]
{ {
@ -721,11 +721,11 @@ int main(int /*argc*/, char** /*argv*/)
std::this_thread::sleep_for(std::chrono::milliseconds(50)); 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)); // std::this_thread::sleep_for(std::chrono::seconds(5));
pool.Await(); pool.Await();
countPool.Await(); countPool.Await();