sharedQueue.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 1992-2024 MAK Technologies, Inc
** All rights reserved.
******************************************************************************/


#ifndef sharedQueue_H_
#define sharedQueue_H_

#include <deque>
#include <lgrUtil/threadSafe.h>
#include <lgrUtil/collectors.h>

namespace MAKLogger
{

   template <typename T>
   class DtSharedQueue
   {
   public:

      DtSharedQueue() : myDeque(std::deque<T> ())
      {
      }

      DtSharedQueue(const DtSharedQueue& original)
      {
         *myDeque = *original.myDeque;
      }

      int size() const
      {      
         return static_cast<int>(myDeque->size());
      }

      void clear()
      {
         myDeque->clear();
      }

      void push(const T& input)
      {
         myDeque->push_back(input);
      }

      void push_priority(const T& input)
      {
         myDeque->push_front(input);
      }

      bool pop(T& output)
      {
         DtScopedSequenceLock lock = myDeque.sequenceLock();
         if(myDeque->empty() == false)
         {      
            output = myDeque->front();
            myDeque->pop_front();
            return true;
         }
         return false;
      }

      void move(DtCollector<T>& output)
      {
         DtScopedSequenceLock lock     = myDeque.sequenceLock();        
         typename std::deque<T>::iterator startIter  = myDeque->begin();
         typename std::deque<T>::iterator endIter    = myDeque->end();
         for(;startIter != endIter;++startIter)
         {
            output.collect(*startIter);
         }
         myDeque->clear();
      }

   protected:
      DtThreadSafe<std::deque<T> > myDeque;
   };

}

#endif