---

/home/pauldt/projects/IDEA/IDEA-ALL/IDEA-DEV/Core/Agent/Includes/Queue.hh

Go to the documentation of this file.

// -*- Mode: c++ -*-
//     File: $Source: /home/cvs/ISG-Repository/IDEA-DEV/Core/Agent/Includes/Queue.hh,v $
//      Tag: $Name: DR_01_11_06 $
//      CVS: $Id: Queue.hh,v 1.4 2005/12/30 22:05:34 rijsman Exp $
//     Info: $CVSROOT/IDEA-DEV/COPYRIGHT

#ifndef _HEADER_THREAD_SAFE_QUEUE_HEADER__
#define _HEADER_THREAD_SAFE_QUEUE_HEADER__

#include <assert.h>

/* STL-INCLUDES */
#include <queue>
#include <vector>

#include "ThreadTools.hh"

namespace IDEA
{
  template<class Type, class Container = std::vector< Type >, class Compare = std::less< typename Container::value_type > >
  class ThreadSafeQueue
  {
  public:
    ThreadSafeQueue():
      m_Mutex("ThreadSafeQueue") 
    {
    }
  
    ~ThreadSafeQueue() 
    {
    }

    inline bool empty()
    {
      Guard<RecursiveThreadMutex> guard(m_Mutex, "ThreadSafeQueue::empty");

      return m_Queue.empty();
    }

    inline const Type& top() 
    {
      Guard<RecursiveThreadMutex> guard(m_Mutex, "ThreadSafeQueue::top");

      return m_Queue.top();
    }

    inline void pop()
    {  
      Guard<RecursiveThreadMutex> guard(m_Mutex, "ThreadSafeQueue::pop");

      m_Queue.pop();
    }

    inline void push(const Type& v ) 
    { 
      Guard<RecursiveThreadMutex> guard(m_Mutex, "ThreadSafeQueue::push");

      m_Queue.push( v );
    };

    inline size_t size() 
    {
      Guard<RecursiveThreadMutex> guard(m_Mutex, "ThreadSafeQueue::size" );

      return m_Queue.size();
    }

    inline size_t size() const
    {
      Guard<RecursiveThreadMutex> guard(m_Mutex, "ThreadSafeQueue::size");

      return m_Queue.size();    
    }
  
    RecursiveThreadMutex& getMutex() { return m_Mutex; }
  private:
    RecursiveThreadMutex m_Mutex; 
    std::priority_queue<Type,Container,Compare> m_Queue; 
  };
} //namespace IDEA

#endif  //_HEADER_THREAD_SAFE_QUEUE_HEADER__

---

Contact information © IDEA