fixes #65

tested on AIX

Author: Herbert Koelman

include/pthread/lock_guard.hpp

@@ -47,8 +47,9 @@ namespace pthread {
      *
      * @param m reference to a valid pthread::mutex
      */
-    explicit lock_guard(MutexType &m): _mutex(&m) {
-        _mutex->lock();
+    explicit lock_guard(MutexType &m){ //: _mutex(&m) {
+      _mutex = &m ;
+      _mutex->lock();
     }
 
     /** The destructor release the guarded mutex.

include/pthread/sync_queue.hpp

@@ -80,19 +80,23 @@ namespace pthread {
       }
 
       /** @return current number of elements in the queue */
-      size_t size() const {
 #if __cplusplus < 201103L
+      size_t size() const {
         // we use read/write locks when std::atomic is not available
         pthread::lock_guard<pthread::read_lock> lck(_rwlock);
+#else
+      size_t size() const {
 #endif
         return _items.size();
       }
 
       /** @return maximun number of items that can be put in the queue */
-      size_t max_size() const {
 #if __cplusplus < 201103L
+      size_t max_size() {
         // we use read/write locks when std::atomic is not available
         pthread::lock_guard<pthread::read_lock> lck(_rwlock);
+#else
+      size_t max_size() const {
 #endif
         return _max_size ;
       }

tests/synchronized_queue_tests.cpp

@@ -9,7 +9,7 @@
 #include <memory>
 #include <ctime>
 
-#define MESSAGES_TO_PRODUCE 10 //500000 // messages produced
+#define MESSAGES_TO_PRODUCE 5000 // messages produced
 #define CONSUMER_PROCESSING_DURATION 20 // millis
 
 #define CONSUMERS 10 // number of consumer threads