refs #194

Author: HerbertKoelman

tests/abstract_thread_tests.cpp

@@ -21,7 +21,7 @@ class test_thread : public pthread::abstract_thread {
         try {
             long counter = 0;
             std::cout << std::flush << "Test thread is running..." << std::flush;
-            pthread::this_thread::sleep_for(25 * 100);
+            pthread::this_thread::sleep_for(2 * 100);
             for (auto count = 1000; count > 0; count--) {
                 counter += count;
             }

tests/synchronized_queue_tests.cpp

@@ -96,7 +96,7 @@ class producer : public status, public pthread::abstract_thread {
     void run() throw() {
 #else
 
-    void run() noexcept {
+    void run() noexcept override {
 #endif
         printf("start producing %d messages\n", MESSAGES_TO_PRODUCE);
         for (auto x = MESSAGES_TO_PRODUCE; (x > 0) && running(); x--) {
@@ -122,7 +122,7 @@ class consumer : public status, public pthread::abstract_thread {
     void run() throw() {
 #else
 
-    void run() noexcept {
+    void run() noexcept override {
 #endif
 
         printf("starting consumer\n");
@@ -139,7 +139,7 @@ class consumer : public status, public pthread::abstract_thread {
                 }
 
                 if ((100 % counter()) == 0) {
-                    printf("queue's current content is %zu (thrd: %o );\n", _queue.size(), pthread::this_thread::get_id());
+                    printf("[handle 100] queue's current content is %zu (thrd: %o );\n", _queue.size(), pthread::this_thread::get_id());
                 }
 
                 pthread::this_thread::sleep_for(CONSUMER_PROCESSING_DURATION);

tests/thread_tests.cpp

@@ -20,7 +20,7 @@ class test_runnable : public pthread::runnable {
         try {
             long counter = 0;
             display_message("test_runnable is running ");
-            pthread::this_thread::sleep_for(2 * 1000);
+            pthread::this_thread::sleep_for(2 * 100);
             for (auto count = 1000; count > 0; count--) {
                 counter += count;
             }