diff Core/MultiThreading/SharedMessageQueue.h @ 452:80f7539147a2

WaitEmpty
author Sebastien Jodogne <s.jodogne@gmail.com>
date Thu, 04 Jul 2013 11:48:02 +0200
parents 0e8bd937a0f3
children 2d0a347e8cfc
line wrap: on
line diff
--- a/Core/MultiThreading/SharedMessageQueue.h	Thu Jul 04 09:53:15 2013 +0200
+++ b/Core/MultiThreading/SharedMessageQueue.h	Thu Jul 04 11:48:02 2013 +0200
@@ -49,6 +49,7 @@
     Queue queue_;
     boost::mutex mutex_;
     boost::condition_variable elementAvailable_;
+    boost::condition_variable emptied_;
 
   public:
     SharedMessageQueue(unsigned int maxSize = 0);
@@ -60,5 +61,7 @@
 
     // The caller is responsible to delete the dequeud message!
     IDynamicObject* Dequeue(int32_t millisecondsTimeout);
+
+    bool WaitEmpty(int32_t millisecondsTimeout);
   };
 }