wefts_queue.h

Go to the documentation of this file.

/*
   wefts_queue.h
   Waitable template FIFO structure.

   $Id: wefts_queue.h,v 1.3 2004/03/08 20:28:53 jonnymind Exp $
---------------------------------------------
   Begin      : 2003-08-03 17:50
   Author     : Giancarlo Niccolai

   Last modified because:

*/

/**************************************************************************
*   This program is free software; you can redistribute it and/or modify  *
*   it under the terms of the GNU Library General Public License as       *
*   published by the Free Software Foundation; either version 2.1 of the  *
*   License, or (at your option) any later version.                       *
***************************************************************************/


#ifndef WT_QUEUE_H
#define WT_QUEUE_H

#include <wefts_fastcond.h>
#include <list>

namespace Wefts {

template <class T>
class Queue {
private:
   void p_waitForFree() {
      while ( m_list.size() >= m_maxLen )
         m_cond.wait();
   }

   void p_waitForFull() {
      while ( m_list.size() == 0 )
         m_cond.wait();
   }

protected:
   FastCondition m_cond;
   unsigned long m_maxLen;
   std::list<T> m_list;

public:
   Queue( unsigned int maxLen = 0) {
      m_maxLen = maxLen;
   }

   bool push( T elem, const bool wait=false)
   {
      m_cond.lock();
      if ( m_maxLen > 0 && m_list.size() >= m_maxLen )
      {
         if ( wait ) {
            // this is for compilers that canno expand loops inline
            p_waitForFree();
         }
         else {
            m_cond.unlock();
            return false;
         }
      }
      m_list.push_back( elem );
      m_cond.signal();
      m_cond.unlock();
      return true;
   }


   bool pop( T &elem, const bool wait=true)
   {
      m_cond.lock();
      if ( m_list.size() == 0 )
      {
         if ( wait ) {
            // this is for compilers that canno expand loops inline
            p_waitForFull();
         }
         else {
            m_cond.unlock();
            return false;
         }
      }
      elem = m_list.front();
      m_list.pop_front();
      m_cond.signal();
      m_cond.unlock();
      return true;
   }

};

}

#endif
/* end of wefts_queue.h */

---