ifixes #157 @1h

Author: HerbertKoelman

include/pthread/sync_queue.hpp

@@ -53,7 +53,9 @@ namespace pthread {
        */
       void put (const T& item);
 
-      /** Put an item in the queue (wait if size >= max_size).
+      /** Put an item in the queue.
+       *
+       * If the queue size is greater or equal to max_size, then wait for the wiat-time millis for the queue to empty a bit.
        *
        * @param item item to store in the queue
        * @param wait_time millis to wait for the queue to free a slo
@@ -62,13 +64,13 @@ namespace pthread {
 
       /** Get an item from the queue.
        *
-       * If the queue is empty, get waits for an item to be put.
+       * If the queue is empty,  the method blocks until an item is entered in the queue.
        *
        * @param item item that will receive an item found onto the queue.
        */
       void get ( T& item);
 
-      /** Get an item from the queue, if empty wait for one during duration milliseconds.
+      /** Get an item from the queue, if the queue is empty, then wait for an element wait_time milliseconds.
        *
        * @param item item that will receive an item found onto the queue.
        * @param wait_time duration we are willing to wait for a new item.

tests/synchronized_queue_tests.cpp

@@ -127,7 +127,7 @@ class producer : public status, public pthread::abstract_thread {
 
             //pthread::this_thread::sleep_for(1*1000);
         }
-        printf("send stop producing message\n");
+        std::cout << "send stop message" << std::endl;
         message_ptr pmessage(new message("stop", -1));
         _queue.put(pmessage);
     };
@@ -160,8 +160,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("queue's current content is %zu (thrd: %o );\n", _queue.size(), pthread::this_thread::get_id());
                 }
 
                 pthread::this_thread::sleep_for(CONSUMER_PROCESSING_DURATION);
@@ -175,6 +174,7 @@ class consumer : public status, public pthread::abstract_thread {
                 printf("queue get timed out (%s, at %d)\n", __FILE__, __LINE__);
             }
         }
+
         printf("stopping consumer\n");
     };
 
@@ -232,7 +232,7 @@ TEST(synchronized_queue, producer_consumer) {
         // The + 1 is because we send one more message: a stop message
         EXPECT_EQ(MESSAGES_TO_PRODUCE + 1, consumed_messages);
 
-        printf("threads joined main program, consumed %d messages (%s, %d)\n", consumed_messages, __FILE__, __LINE__);
+        std::cout << "threads joined main program, consumed " << consumed_messages << " messages" << std::endl;
 
         pstatus = EXIT_SUCCESS;
     } catch (std::exception &err) {