TwoWayThreadModule.h

Go to the documentation of this file.

/*******************************************************************************
 *  TwoWayThreadModule.h
 *
 *  (C) 2006 AG Aktives Sehen <agas@uni-koblenz.de>
 *           Universitaet Koblenz-Landau
 *
 *  Additional information:
 *  $Id: TwoWayThreadModule.h 44313 2011-04-06 22:46:28Z agas $
 ******************************************************************************/

#ifndef TWOWAYTHREADMODULE_H
#define TWOWAYTHREADMODULE_H

#include "Thread.h"
#include "Condition.h"
#include "ThreadQueue.h"

template<class OutT, class InT>
class TwoWayThreadModule : public Thread
{

  public:

    TwoWayThreadModule( size_t numInQueues ) : Thread()
    {

    }

    virtual ~TwoWayThreadModule()
    {}

    void pushOut ( OutT element, size_t queueId )
    {
      m_OutboundQueue.push ( element );
    }

    OutT popOut()
    {
      return ( m_OutboundQueue.pop() );
    }

    int sizeOut()
    {
      return m_OutboundQueue.size();
    }

    void pushIn ( InT element )
    {
      m_InboundQueue.push ( element );
    }

    InT popIn()
    {
      return ( m_InboundQueue.pop() );
    }

    bool emptyIn()
    {
      return m_InboundQueue.empty();
    }

    int sizeIn()
    {
      return m_InboundQueue.size();
    }

  protected:

};

#endif