containers_cpp: add tests for blocking priority queue + get rid of namespace in…

containers_cpp: add tests for blocking priority queue + get rid of namespace in blocking container class

containers_cpp/include/embb/containers/blocking_container.h

@@ -34,7 +34,6 @@
 namespace embb {
 namespace embb {
 namespace containers {
 namespace containers {
 
 
-using namespace base;
 
 
 /*
 /*
 * Abstract class to use for the implementation of blocking datastructure.
 * Abstract class to use for the implementation of blocking datastructure.
@@ -44,6 +43,7 @@ using namespace base;
 */
 */
 template < typename Type >
 template < typename Type >
 class BlockingContainer {
 class BlockingContainer {
+  typedef embb::base::Mutex Mutex;
  protected:
  protected:
   /*
   /*
   * Mutex for thread synchronization.
   * Mutex for thread synchronization.
@@ -54,7 +54,7 @@ class BlockingContainer {
   * Condition variable for notifying threads that are waiting
   * Condition variable for notifying threads that are waiting
   * for popping elements that new elements are available.
   * for popping elements that new elements are available.
   */
   */
-  ConditionVariable condition;
+  embb::base::ConditionVariable condition;
 
 
   /**
   /**
   * Pure virtual method to be implemented in derived classes.
   * Pure virtual method to be implemented in derived classes.

containers_cpp/include/embb/containers/internal/blocking_container-inl.h

@@ -35,7 +35,7 @@ namespace containers {
 
 
 template<typename T>
 template<typename T>
 void BlockingContainer<T>::PushAndWakeUp(const T& element) {
 void BlockingContainer<T>::PushAndWakeUp(const T& element) {
-  LockGuard<Mutex> lock(mutex);
+  embb::base::LockGuard<Mutex> lock(mutex);
 
 
   SpecializedPush(element);
   SpecializedPush(element);
 
 
@@ -44,7 +44,7 @@ void BlockingContainer<T>::PushAndWakeUp(const T& element) {
 
 
 template<typename T>
 template<typename T>
 void BlockingContainer<T>::BlockingPop(T& element) {
 void BlockingContainer<T>::BlockingPop(T& element) {
-  UniqueLock<Mutex> lock(mutex);
+  embb::base::UniqueLock<Mutex> lock(mutex);
 
 
   while (IsEmpty()) {
   while (IsEmpty()) {
     condition.Wait(lock);
     condition.Wait(lock);

containers_cpp/test/main.cc

@@ -32,6 +32,7 @@
 #include <embb/containers/blocking_stack.h>
 #include <embb/containers/blocking_stack.h>
 #include <embb/containers/lock_free_mpmc_queue.h>
 #include <embb/containers/lock_free_mpmc_queue.h>
 #include <embb/containers/blocking_queue.h>
 #include <embb/containers/blocking_queue.h>
+#include <embb/containers/blocking_priority_queue.h>
 #include <embb/containers/blocking_set.h>
 #include <embb/containers/blocking_set.h>
 #include <embb/containers/blocking_map.h>
 #include <embb/containers/blocking_map.h>
 #include <embb/base/c/memory_allocation.h>
 #include <embb/base/c/memory_allocation.h>
@@ -56,6 +57,7 @@ using embb::containers::LockFreeTreeValuePool;
 using embb::containers::WaitFreeSPSCQueue;
 using embb::containers::WaitFreeSPSCQueue;
 using embb::containers::LockFreeMPMCQueue;
 using embb::containers::LockFreeMPMCQueue;
 using embb::containers::BlockingQueue;
 using embb::containers::BlockingQueue;
+using embb::containers::BlockingPriorityQueue;
 using embb::containers::LockFreeStack;
 using embb::containers::LockFreeStack;
 using embb::containers::BlockingStack;
 using embb::containers::BlockingStack;
 using embb::containers::LockFreeTreeValuePool;
 using embb::containers::LockFreeTreeValuePool;
@@ -86,6 +88,7 @@ PT_MAIN("Data Structures C++") {
   PT_RUN(QueueTest< LockFreeMPMCQueue< ::std::pair<size_t COMMA int> >
   PT_RUN(QueueTest< LockFreeMPMCQueue< ::std::pair<size_t COMMA int> >
     COMMA true COMMA true >);
     COMMA true COMMA true >);
   PT_RUN(BlockingQueueTest< BlockingQueue<int> >);
   PT_RUN(BlockingQueueTest< BlockingQueue<int> >);
+  PT_RUN(BlockingQueueTest< BlockingPriorityQueue<int> >);
   PT_RUN(StackTest< LockFreeStack<int> >);
   PT_RUN(StackTest< LockFreeStack<int> >);
   PT_RUN(BlockingStackTest< BlockingStack<int> >);
   PT_RUN(BlockingStackTest< BlockingStack<int> >);
   PT_RUN(SetTest< BlockingSet<int> >);
   PT_RUN(SetTest< BlockingSet<int> >);